Тайм-аут соединения с Kafka, работающим с подсистемой Windows для Linux - PullRequest
Новая
       8

Тайм-аут соединения с Kafka, работающим с подсистемой Windows для Linux

0 голосов
/ 11 мая 2018

Я установил Kafka 1.1.0 с Zookeeper 3.4.12 в подсистеме Windows для Linux на моем ноутбуке с Windows 10. Я могу прокусить и использовать сообщения, пока я нахожусь в Ubuntu, но когда я хочу создать сообщение из Windows (с помощью Java-программы или с помощью инструмента kafka-console -roduction.bat), у меня появляется следующая ошибка:

[2018-05-11 15: 31: 01,449] ОШИБКА Ошибка при отправке сообщения в тест темы с ключом: ноль, значение: 15 байт с ошибкой: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.TimeoutException: срок действия 1 записей для теста 0: 1534 мс прошло с момента создания пакета плюс время ожидания

Есть идеи?

1 Ответ

0 голосов
/ 28 июня 2018

У меня была похожая проблема, и я решил ее, тестируя kafka из консоли следующим образом:

  1. Создание темы: bin / kafka-topics.sh --zookeeper zooker-domain: 2181--create --topic test --replication-factor 1 --partitions 1

  2. Вставка сообщения: bin / kafka-console-producer.sh --broker-list kafka-domain: 9092 - топический тест

  3. Использование сообщений: (старый API) bin / kafka-console-consumer.sh --zookeeper zookeeper-domain: 2181 - топический тест --from-начало
    (или с новым API) bin / kafka-console-consumer.sh - новый потребитель - топический тест --от начала - baftstrap-сервер kafka-домен: 9092 - раздел 0

(Вместо доменов вы можете использовать непосредственно IP-адреса).

Я протестировал его с kafka 0.11.0.1, и он работает.

Если у вас все еще есть проблемы, попробуйтес: https://stackoverflow.com/a/51071306/2493852

...