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.
The share consumer container publishes
ConsumerStartingEventandConsumerStartedEventbut no stop or failure events.wrapUp()only callsconsumer.close()— no event publishing.ConsumerStoppedEventandConsumerFailedToStartEventtake genericObjectparameters and can be reused directly.ConsumerStoppingEventtakesConsumer<?, ?>andCollection<TopicPartition>, which won't work —ShareConsumerdoes not extendConsumerand share consumers have no partition assignments. This needs either a newShareConsumerStoppingEventor a refactor of the existing event.