काफ्का विषय बनाने में त्रुटि- उपलब्ध दलालों से बड़ा प्रतिकृति कारक

Question

मैं कमांड लाइन के माध्यम से अपाचे काफ्का वेबसाइट पर मार्गदर्शिका का पालन करके काफ्का में विषयों को बनाने की कोशिश कर रहा हूं। आदेश चलाकर जबकि:

Error while executing topic command replication factor: 1 larger than available 
brokers: 0 
kafka.admin.AdminOperationException: replication factor: 1 larger than available 
brokers: 0 
     at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70) 
     at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171) 
     at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93) 
     at kafka.admin.TopicCommand$.main(TopicCommand.scala:55) 
     at kafka.admin.TopicCommand.main(TopicCommand.scala) 

[2015-10-13 14:25:38,607] INFO Processed session termination for sessionid: 0x15 
06056566d0004 (org.apache.zookeeper.server.PrepRequestProcessor) 
[2015-10-13 14:25:38,608] INFO Closed socket connection for client /127.0.0.1:33 
391 which had sessionid 0x1506056566d0004 (org.apache.zookeeper.server.NIOServer 
Cnxn) 

मैं इस मुद्दे का समाधान कैसे कर सकते हैं:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 

इस प्रकार मैं त्रुटि मिलती है? इसके साथ शुरू करने के लिए कोई अच्छा दस्तावेज? धन्यवाद !!

Answer 1

मुझे एक ही समस्या है। आपको गाइड के इस भाग का पालन करना होगा: http://kafka.apache.org/documentation.html#quickstart_multibroker

मेरे पास कोई भी ब्रोकर नहीं था। 2 नए ब्रोकर बनाएं और आप समस्या को ठीक करेंगे। का पालन करें इस कदम:

cp config/server.properties config/server-1.properties 
cp config/server.properties config/server-2.properties 

एक बार जब आप बनाने फ़ाइलें आप इस के साथ इसे कॉन्फ़िगर के लिए कुछ परिवर्तन किया है:

"server-1.properties" में:

broker.id=1 
port=9093 
log.dir=/tmp/kafka-logs-1 
host.name=localhost 

(पोर्ट नंबर चाहिए आपके सर्वर में पोर्ट नंबर हो .properties + 1. मेरे पास 9 0 9 0 था इसलिए मुझे 90 9 3 लिखना है)

"server-2.properties" में:

broker.id=2 
port=9094 
log.dir=/tmp/kafka-logs-2 
host.name=localhost 

(पोर्ट नंबर सर्वर -1 के बगल में होना चाहिए। मेरे मामले में 9 0 9 4)

Answer 2

यह स्पष्ट रूप से कहता है कि 0 ब्रोकर उपलब्ध है। अपाचे काफ्का ट्यूटोरियल पर

bin/zookeeper-server-start.sh config/zookeeper.properties 
bin/kafka-server-start.sh config/server.properties 

आधार द्वारा एक दलाल शुरू तो, कोशिश

Answer 3

लगता है अपने सर्वर की तरह शुरू नहीं मुद्दा

को मार डालो प्रक्रिया

sudo fuser -k 2181/tcp 

रन चिड़ियाघर संचालक

के लिए जाँच लॉग

bin/zookeeper-server-start.sh config/zookeeper.properties 

भागो काफ्का

bin/kafka-server-start.sh config/server.properties ' 

Answer 4

अगर मैं तुम्हें थे मैं इस कोड की कोशिश करेंगे:

bin/kafka-topics.sh --create --zookeeper स्थानीय होस्ट: 2181/काफ्का --replication- कारक 1 --partitions 1 --topic परीक्षण

आप एक क्लस्टर जहां चिड़ियाघर संचालक 3 नोड्स में वितरित किया जा प्रयोग कर रहे हैं आप direccion1:2181,direction2:2181,direction3:2181/kafka

के लिए localhost:2181/kafka substitue चाहिए

Answer 5

मुझे एक ही समस्या है। मैं समस्या का समाधान करता हूं। मुझे लगता है कि इसका कारण यह है कि कोई पृष्ठभूमि स्टार्ट-अप नहीं है। हां, तो हम शुरू हुआ पृष्ठभूमि neet

bin/kafka-server-start.sh config/server.properties & 
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test & 

Answer 6

आपका Zookeeper अपने Zookeepr कंसोल में किसी भी काफ्का brokers.Try लॉगिंग को देखने में असमर्थ है: कंसोल पर bin/zkCli.sh -server localhost:2181 भागो [zk: localhost:2181(CONNECTED) 2] ls /brokers/ids। यह किसी भी दलाल को नहीं दिखाया जाना चाहिए। आपको अपने सभी काफ्का दलालों को पुनरारंभ करने की आवश्यकता है, और कफका प्रक्रिया लॉग की जांच करें। कभी-कभी, जब भी प्रक्रिया चलती है (ps -ef | grep kafka), यह वास्तव में पूरी तरह से शुरू नहीं हो सकता है, जिसके कारण ज़ुकीपर इसे देखने में असमर्थ है। अपाचे काफ्का वितरण 0.11.0 के साथ मेरा एक ही मुद्दा था।