Details
-
Task
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Currently KafkaConsumer creates instance of NoOpConsumerRebalanceListener for each subscribe() call where ConsumerRebalanceListener is not specified:
public void subscribe(Pattern pattern) { subscribe(pattern, new NoOpConsumerRebalanceListener());
We can create a singleton NoOpConsumerRebalanceListener to be used in such scenarios.