Через некоторое время после подключения второго потребителя с таким же идентификатором группы я получаю сообщение об ошибке
«Экземпляр получателя не найден» (код: 40403).
Я заметил, что при подключении второго потребителя мой запрос на получение новых сообщений от Kafka
зависает для обоих потребителей. Я убежден, что ошибка, которую я получаю, является результатом проблемы, а не причиной, потому что после зависания запроса истекает тайм-аут для потребителя, и он автоматически удаляется. Однако я не понимаю, почему запрос зависает.
На момент возникновения проблемы очередь Kafka's
пуста.
Конфигурация имеет значение:
zookeeper.connect
bootstrap.servers
Другие значения установлены по умолчанию.
Я думал, что это было связано с ограничением пользовательских потоков (consumer.threads
), но в документации сказано, что по умолчанию установлено значение 50
.
https://docs.confluent.io/current/kafka-rest/config.html