5
अच्छी तरह से ... दुनिया में हर सेवा मेरी ज़ूकीपर उम्मीद कफका से जुड़ सकती है। नीचे server.properties में मेरी कनेक्शन स्ट्रिंग फ़ाइलकफका ज़ुकीपर से कनेक्ट नहीं हो सकता- काफकासेवरस्टेबल स्टार्टअप
zk.connect=1.dzk.syd.druid.neo.com:2181, 2.dzk.syd.druid.neo.com:2181
दो चिड़ियाघर संचालक सर्वर .... कुल अनेक मोड पर सभी बंदरगाहों है है है। मैं भी .. काफ्का सर्वर से चिड़ियाघर संचालक सर्वर में टेलनेट कर सकते हैं
telnet 2.dzk.syd.druid.neo.com 2181
Trying 54.252.183.218...
Connected to 2.dzk.syd.druid.neo.com.
Escape character is '^]'.
तो .... चिड़ियाघर संचालक को नहीं बल्कि क्यों काफ्का कनेक्ट नहीं होगा पर उलझन में?
मैं ubuntu उपयोग कर रहा हूँ 12.04 और काफ्का 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)
मुझे समस्या मिली, kafka कनेक्शन स्ट्रिंग-> zk.connect = 1.dzk.syd.druid में कोई स्थान पसंद नहीं है। neo.com:2181,2.dzk.syd.druid.neo.com:21 81 – Tampa
मुझे स्पार्क स्ट्रीमिंग एप्लिकेशन में एक ही समस्या थी जो काफ्का से जुड़ती है। कॉमा के बाद रिक्त स्थान को हटाकर भी ठीक किया गया था। – davidpricedev
@Tampa क्या आप यहां एक टिप्पणी के रूप में अपनी टिप्पणी जोड़ सकते हैं और इसे स्वीकार कर सकते हैं? यह स्पार्क से एचबीज़ को जोड़ने के लिए भी काम करता था। – adamdunson