Skip to content

Kafka Index Task should remember end offsets set by supervisor #4177

@pjain1

Description

@pjain1

Kafka Index Task cannot restore end offsets set by supervisor if the middleManager restarts after end offsets have been set and the task is not complete yet. Thus, it can keep on consuming records that it should not after restore.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions