Skip to content

Add AcknowledgementCommitCallback support to share consumer container #4323

@sobychacko

Description

@sobychacko

AcknowledgementCommitCallback (KIP-932) is invoked when acknowledgments are durably persisted broker-side:

void onComplete(Map<TopicIdPartition, Set<Long>>, Exception)

Currently there is no wiring in the share consumer container or ContainerProperties.

Add ContainerProperties.setAcknowledgementCommitCallback(AcknowledgementCommitCallback) and pass it through to the ShareConsumer. Needed when coordinating acknowledgment persistence with external systems (e.g., updating a database only after the broker confirms the ack).

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions