The first call to KafkaConsumer#poll still returns messages: ... consumer resumed by Kafka due to rebalance; " "the container will pause again before polling, ...
DOWNLOAD: https://tinurli.com/2ejwaa
DOWNLOAD: https://tinurli.com/2ejwaa
kafka-consumer-pause-rebalance
Sep 26, 2018 — If a rebalance occurs while a KafkaMessageListenerContainer is paused, consumption of records will resume and it will not be possible to pause .... consumer.pause(singleton(tp0)); ... Properties properties;new KafkaConsumer(properties); Codota Icon ... WorkerSinkTask$HandleRebalance. 3925e8d270
Comments