Hi all,

I'd like to start a discussion on KIP-1306: RebalanceHandler: Consumer-Aware 
Rebalance Callback.

https://cwiki.apache.org/confluence/display/KAFKA/KIP-1306%3A+RebalanceHandler%3A+Consumer-Aware+Rebalance+Callback

Spring Kafka, SmallRye, and Micronaut all pass the consumer into rebalance 
callbacks; the client doesn't. The standard workaround of constructor-injecting 
a full Consumer reference allows dangerous operations like poll() and close() 
inside a callback. This KIP proposes RebalanceHandler, with a 
RebalanceConsumerView that exposes only safe operations, making misuse a 
compile error.

Looking forward to your feedback.

Thanks

Reply via email to