KafkaConsumersManager seems to never register the consumer.

bootique / bootique-kafka

Provides integration of Kafka client and streams with Bootique

http://bootique.io

Apache License 2.0

4 stars 4 forks source link

KafkaConsumersManager seems to never register the consumer. #26

Closed const1993 closed 5 years ago

const1993 commented 5 years ago

As I understand the the consumer should be automatically added to 'KafkaConsumersManager' after creation in 'KafkaClientFactoryFactory' to be correctly closed on shutdown, but the 'register' method is never called.