Я пытаюсь создать кластер Kafka
для отправки сообщений на пульт дистанционного управления. Я сконфигурировал все, как описано здесь.
Я запускаю это на машине Linux red hat
, и он отлично работает с помощью оболочки. После написания java-кода, как описано в учебнике quick start
на моем компьютере с Windows, я получил следующую ошибку:
...
DEBUG kafka.client.ClientUtils$ - Successfully fetched metadata for 1 topic(s) Set(example)
...
ERROR kafka.producer.SyncProducer - Producer connection to cldExampleKafka.domain:80 unsuccessful
java.nio.channels.UnresolvedAddressException
...
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44)
...
WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 2 to broker 0 with data for patitions [ati,0]
java.nio.channels.UnresolvedAddressException
...
kafka.common.FailedToSendMessageException: Failed to send message after 3 tries.
Я также попытался запустить банку на другой машине Linux и по-прежнему получил ту же ошибку.
Измените адрес на localhost
и запустите java-код как банку на машине, где установлен kafka.
Я верю в это что-то с конфигурацией, но я не смог ее найти.