kafkaServerStable başlangıcında zookeeper- FATAL ölümcül hataya bağlanın

Dünyadaki tüm servisler kafo'ya bağlanabiliyor. Aşağıda server.properties benim bağlantı dizesi kafkaServerStable başlangıcında zookeeper- FATAL ölümcül hataya bağlanın

zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181

iki Yaupon sunucularına .... toplam promiscuous tüm portları var mı dosyası olduğunu. Hatta

telnet 2.dzk.syd.druid.neo.com 2181 
Trying 54.252.183.218... 
Connected to 2.dzk.syd.druid.neo.com. 
Escape character is '^]'.

Yani .... kafka bağlanmıyor neden oldukça karışık hayvan bakıcısı için .. kafka sunucusundan Yaupon sunucusuna telnet olabilir?

Ben senin kafka/config/server.properties ise Ubuntu 12.04 ve Kafka 0.7.2

[2013-07-16 04:36:49,915] INFO Client environment:user.home=/root (org.apache.zookeeper.ZooKeeper) 
[2013-07-16 04:36:49,915] INFO Client environment:user.dir=/etc/sv/kafka (org.apache.zookeeper.ZooKeeper) 
[2013-07-16 04:36:49,916] INFO Initiating client connection, connectString=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181 sessionTimeout=6000 [email protected] (org.apache.zookeeper.ZooKeeper) 
[2013-07-16 04:36:49,935] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread) 
[2013-07-16 04:36:49,938] FATAL Fatal error during KafkaServerStable startup. Prepare to shutdown (kafka.server.KafkaServerStartable) 
org.I0Itec.zkclient.exception.ZkException: Unable to connect to 1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181 
    at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:66) 
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:872) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) 
    at kafka.server.KafkaZooKeeper.startup(KafkaZooKeeper.scala:44) 
    at kafka.log.LogManager.<init>(LogManager.scala:93) 
    at kafka.server.KafkaServer.startup(KafkaServer.scala:58) 
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34) 
    at kafka.Kafka$.main(Kafka.scala:47) 
    at kafka.Kafka.main(Kafka.scala) 
Caused by: java.net.UnknownHostException: 2.dzk.syd.druid.neo.com: Name or service not known 
    at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) 
    at java.net.InetAddress$1.lookupAllHostAddr(InetAddress.java:894) 
    at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1286) 
    at java.net.InetAddress.getAllByName0(InetAddress.java:1239) 
    at java.net.InetAddress.getAllByName(InetAddress.java:1155) 
    at java.net.InetAddress.getAllByName(InetAddress.java:1091) 
    at org.apache.zookeeper.ClientCnxn.<init>(ClientCnxn.java:387) 
    at org.apache.zookeeper.ClientCnxn.<init>(ClientCnxn.java:332) 
    at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:383) 
    at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64) 
    ... 9 more 
[2013-07-16 04:36:49,942] INFO Shutting down Kafka server (kafka.server.KafkaServer) 
[2013-07-16 04:36:49,943] INFO shutdown scheduler kafka-logcleaner- (kafka.utils.KafkaScheduler) 
[2013-07-16 04:36:49,944] INFO Kafka server shut down completed (kafka.server.KafkaServer)

kaynak

2013-07-16 Tampa

olmalıdır. Sorunu fark ettim, kafka bağlantı dizesindeki bir alanı sevmiyor -> zk.connect = 1.dzk.syd.druid. neo.com:2181,2.dzk.syd.druid.neo.com:21 81 – Tampa

Aynı sorunu Kafka'ya bağlanan Spark Streaming uygulamasında da yaşadım. Virgüllerden sonra boşlukları kaldırmak da orada düzeltildi. – davidpricedev

@Tampa Yorumunuzu buraya bir cevap olarak ekleyebilir ve kabul edebilir misiniz? Bu ayrıca Spark'u HBase'e bağlamaya da çalıştı. – adamdunson

kullanıyorum, orada bu uncommented varsa bir özellik

#host.name=localhost

olabilir veya olmalı Bunu başka bir adaya ayarladığınızda, bu ad/etc/hosts dosyasında

kaynak

2013-11-11 13:38:56

aslında benim için işe yaramadı :( – Adelin

kafkaServerStable başlangıcında zookeeper- FATAL ölümcül hataya bağlanın

cevap

İlgili konular