[
https://issues.apache.org/jira/browse/KAFKA-19694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19694:
--------------------------------------
Assignee: Lucas Brutschy
> StreamsRebalanceListener is not triggered on Consumer.close()
> -------------------------------------------------------------
>
> Key: KAFKA-19694
> URL: https://issues.apache.org/jira/browse/KAFKA-19694
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Lucas Brutschy
> Assignee: Lucas Brutschy
> Priority: Major
>
> In the consumer, we invoke the consumer rebalance {{onPartitionRevoked}} or
> {{onPartitionLost}} callbacks, when the consumer closes. The point is that
> the application may want to commit, or wipe the state if we are closing
> unsuccessfully.
> When Bruno added the {{{}StreamsRebalanceListener{}}}, he did not implement
> this behavior, which means when closing the consumer we may lose some
> progress, and in the worst case also miss that we have to wipe our local
> state state since we got fenced.
> We should implement something like the {{ConsumerRebalanceListenerInvoker}}
> and invoke it in {{{}Consumer.close{}}}.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
