Skip to content

Add stop and failure lifecycle events to share consumer container #4327

@sobychacko

Description

@sobychacko

The share consumer container publishes ConsumerStartingEvent and ConsumerStartedEvent but no stop or failure events.

wrapUp() only calls consumer.close() — no event publishing.

ConsumerStoppedEvent and ConsumerFailedToStartEvent take generic Object parameters and can be reused directly. ConsumerStoppingEvent takes Consumer<?, ?> and Collection<TopicPartition>, which won't work — ShareConsumer does not extend Consumer and share consumers have no partition assignments. This needs either a new ShareConsumerStoppingEvent or a refactor of the existing event.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions