Mikhail Gribkov

NoSuchFieldException when using consumer inherited from KafkaConsumer

7

# Issue description Hey! I'm trying to skip malformed messages by inheriting from KafkaConsumer and altering poll() method behavior. ```java class ExceptionHandlingKafkaConsumer extends KafkaConsumer { public HandlingKafkaConsumer(final Map configs) {...

Consumer stops after rebalance

6

Hey! I have an issue after consumer group rebalance resulting in all partitions being assigned to single consumer. I use the following stream: ```java Scheduler messageHandlingScheduler = Schedulers.newBoundedElastic( 100, Integer.MAX_VALUE,...