Estoy tratando de configurar un clúster de Kafka (el primer nodo en el clúster en realidad).

Tengo una configuración de clúster zookeeper de un solo nodo. Estoy configurando kafka en un nodo separado.

Ambos ejecutan CentOS 6.4, ejecutan IPV6, que es un poco PITA. Verifiqué que las máquinas pueden comunicarse entre sí utilizando netcat.

Cuando inicio kafka, obtengo la siguiente excepción (que hace que kafka se cierre). EDITAR: Empecé kafka, tuve que configurar elhost.name propiedad en el archivo server.config.

Pude crear un tema de prueba y enviar mensajes muy bien desde el servidor kafka.

Sin embargo, obtengo el mismo error cuando intento consumir los mensajes.

¿Alguna ayuda, sugerencias?

bin/kafka-console-consumer.sh --zookeeper zk1:2181 --topic test --from-beginning Exception in thread "main" java.net.UnknownHostException: kafka: kafka: Name or service not known at java.net.InetAddress.getLocalHost(InetAddress.java:1473) at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:107) at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:128) at kafka.consumer.Consumer$.create(ConsumerConnector.scala:89) at kafka.consumer.ConsoleConsumer$.main(ConsoleConsumer.scala:178) at kafka.consumer.ConsoleConsumer.main(ConsoleConsumer.scala) Caused by: java.net.UnknownHostException: kafka: Name or service not known at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) at java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:901) at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1293) at java.net.InetAddress.getLocalHost(InetAddress.java:1469) ... 5 more