New undocumented constructor for Consumer

[alexandernajafi]

The KafkaConsumerBundle does not have any empty constructor, but one that takes a Collection<String> topics and a ConsumerRebalanceListener.

It does not seem like the topics actually does anything as I still, manually have to call subscribe / unsubscribe in my consumer. Is this correct?

Also, could someone please provide some documentation on what to implement in the ConsumerRebalanceListener. It has two methods, but is it OK to leave them empty? Do I have to do some manual commit of offsets here?

new ConsumerRebalanceListener() {
              @Override
              public void onPartitionsRevoked(final Collection<TopicPartition> collection) {
                // Intentionally empty
              }

              @Override
              public void onPartitionsAssigned(final Collection<TopicPartition> collection) {
                // Intentionally empty
              }
            }

[love1491]

Same here, anyone could help? Or should I move to Springboot?