Будет ли KafkaConsumer по-прежнему загружаться в фоновом режиме для разделов тем, которые находятся в состоянии паузы? - PullRequest
0 голосов
/ 22 октября 2018

Я смотрю на исходный код KafkaConsumer здесь .Посмотрев на исходный код (который находится в Java, с которым я не слишком знаком), приостановка раздела раздела, кажется, устанавливает его состояние смещения в состояние паузы.Я пытаюсь выяснить, что происходит с выборками, которые KafkaConsumer делает в фоновом режиме, и останавливает ли остановка раздела раздела предварительную выборку, которую выполняет потребитель kafka, или же он продолжает предварительную выборку, но не возвращает ConsumerRecords для этой темы.раздел в опросе.

1 Ответ

0 голосов
/ 22 октября 2018

Оба.Приостановка раздела останавливает предварительную выборку для этого раздела, а также возвращает пустое значение при опросе.

...