Kafka Rest Api не работает с двумя или более потребителями в одной группе - PullRequest
0 голосов
/ 15 января 2020

Через некоторое время после подключения второго потребителя с таким же идентификатором группы я получаю сообщение об ошибке

«Экземпляр получателя не найден» (код: 40403).

Я заметил, что при подключении второго потребителя мой запрос на получение новых сообщений от Kafka зависает для обоих потребителей. Я убежден, что ошибка, которую я получаю, является результатом проблемы, а не причиной, потому что после зависания запроса истекает тайм-аут для потребителя, и он автоматически удаляется. Однако я не понимаю, почему запрос зависает.

На момент возникновения проблемы очередь Kafka's пуста.

Конфигурация имеет значение:

zookeeper.connect
bootstrap.servers

Другие значения установлены по умолчанию.

Я думал, что это было связано с ограничением пользовательских потоков (consumer.threads), но в документации сказано, что по умолчанию установлено значение 50.

https://docs.confluent.io/current/kafka-rest/config.html

...