kafka.consumer
A base consumer used to abstract both old and new consumer this class should be removed (along with BaseProducer) be removed once we deprecate old consumer
A base consumer used to abstract both old and new consumer this class should be removed (along with BaseProducer) be removed once we deprecate old consumer