Kafka - C # - confluent-kafka-dotnet - Время ожидания сообщения - PullRequest
0 голосов
/ 20 ноября 2018

У нас есть простое развертывание kafka 1.1.0 в автономном режиме на нашей машине с Linux.В файле server.properties мы изменили:

listeners = PLAINTEXT://10.0.5.66:9092

advertised.listeners закомментировано, поэтому оно должно быть возвращено к значению по умолчанию, указанному в свойстве listeners.

Мы используем.NET (C #) производитель, который проталкивает сообщения через confluent-kafka-dotnet (0.11.4).Иногда сообщение передается в Kafka, а иногда мы получаем ошибку «Время ожидания сообщения» на стороне производителя.У нас заканчиваются идеи о том, что может вызвать эту проблему.Это случается время от времени.Если одно сообщение терпит неудачу, другое, которое приходит через несколько секунд после того, как первое обычно проходит.

Другой след может быть в том, что время от времени мы видим следующее сообщение в журналах kafka на сервере: WARN: Attempting to send response via channel for which there is no open connection <IP:PORT>.Это сообщение иногда содержит IP-адрес и порт производителя.

Есть идеи, что может быть не так?

...