Ошибка производителя Kafka Quickstart в Mac OS X
Я продолжаю испытывать раздражающую, периодически возникающую проблему Publisher, пытаясь следовать Kafka Quickstart - Kafka 1.0.0
Зоопарк начинает хорошо - binding to port 0.0.0.0/0.0.0.0:2181
Кафка брокер начинает нормально - Awaiting socket connections on 0.0.0.0:9092
Успешно создать тему test
Config.
Интересные биты конфига в server.properties
broker.id=0
...
port = 9092
advertised.host.name = localhost
...
zookeeper.connect=localhost:2181
Ошибка производителя
Но когда я пытаюсь опубликовать некоторые сообщения test с продюсером я получаю следующую ошибку.
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>message 1
// then it seems to hang
[2018-02-20 14:34:50,145] ERROR Error when sending message to topic test with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms
Раздражает то, что это работало 1 день назад, и теперь я получаю эту ошибку производителя, даже после того, как не изменился конфиг.
Кто-нибудь видел эту ошибку и знает, как ее исправить?
ПРИМЕЧАНИЕ: выключение всегда нечисто
Примечание: Когда я выключаю брокера Kafka, он никогда не делает это так чисто - я не уверен, связано ли это с той же проблемой, что и у меня.
[2018-02-20 14:54:32,774] WARN [KafkaServer id=0] Error during controlled shutdown, possibly because leader movement took longer than the configured controller.socket.timeout.ms and/or request.timeout.ms: Connection to localhost:9092 (id: 0 rack: null) failed. (kafka.server.KafkaServer)
[2018-02-20 14:54:37,783] WARN [KafkaServer id=0] Proceeding to do an unclean shutdown as all the controlled shutdown attempts failed (kafka.server.KafkaServer)
[2018-02-20 14:54:37,785] INFO [SocketServer brokerId=0] Shutting down (kafka.network.SocketServer)