KafkaConsumer<Bytes, Bytes> offsetConsumer;
Consumer<ConsumerRecord<K, V>> testHandler;
EndlessConsumer<K, V> endlessConsumer;
KafkaConsumer<Bytes, Bytes> offsetConsumer;
Consumer<ConsumerRecord<K, V>> testHandler;
EndlessConsumer<K, V> endlessConsumer;