2016-08-03 5 views
0

Я пытаюсь использовать клиента kafka ruby ​​- https://github.com/zendesk/ruby-kafka для размещения журналов в kafka. Ниже приведены бревна из kafkaОшибка отправки сообщения Kafka

I, [2016-08-03T17:54:38.131775 #14887] INFO -- : Fetching cluster metadata from kafka://10.10.10.162:9092 
D, [2016-08-03T17:54:38.131939 #14887] DEBUG -- : Opening connection to 10.40.50.16:9092 with client id ruby-kafka... 
D, [2016-08-03T17:54:38.133199 #14887] DEBUG -- : Sending request 1 to 10.40.50.16:9092 
D, [2016-08-03T17:54:38.133339 #14887] DEBUG -- : Waiting for response 1 from 10.40.50.16:9092 
D, [2016-08-03T17:54:38.134763 #14887] DEBUG -- : Received response 1 from 10.40.50.16:9092 
I, [2016-08-03T17:54:38.134823 #14887] INFO -- : Discovered cluster metadata; nodes: kafka1:9092 (node_id=1), kafka2:9092 (node_id=2), kafka3:9092 (node_id=3) 
D, [2016-08-03T17:54:38.134882 #14887] DEBUG -- : Closing socket to 10.40.50.16:9092 
D, [2016-08-03T17:54:38.135018 #14887] DEBUG -- : Current leader for TRANSACTION_GOCARS/0 is node kafka2:9092 (node_id=2) 
I, [2016-08-03T17:54:38.135092 #14887] INFO -- : Sending 1 messages to kafka2:9092 (node_id=2) 
D, [2016-08-03T17:54:38.135195 #14887] DEBUG -- : Opening connection to kafka2:9092 with client id ruby-kafka... 
E, [2016-08-03T17:54:38.135750 #14887] ERROR -- : Failed to connect to kafka2:9092: getaddrinfo: Name or service not known 
E, [2016-08-03T17:54:38.135825 #14887] ERROR -- : Could not connect to broker kafka2:9092 (node_id=2): getaddrinfo: Name or service not known 

У любого человека есть какая-либо информация о том, как его исправить.

+0

Возможный дубликат [UnknownHostException kafka] (http://stackoverflow.com/questions/25497279/unknownhostexception-kafka) –

ответ

0

Я думаю, что сообщение об ошибке довольно информативно в вашем случае - kafka2 не маршрутировать, поэтому вы должны либо настроить подключение таким образом, что машина, которую вы пытаетесь получить доступ kafka2 от действительно может достичь его или изменить advertised.host.name в Кафке server.properties выставить другой адрес для клиентов

0

попытайтесь выполнить ping или скручивать брокера kafka2 в приложении ur, чтобы узнать, можете ли вы подключиться к нему или нет. или можете сообщить нам server.properties около kafka2. Имя хоста может оказаться недоступным.

Смежные вопросы