Kafka Konular yaratmada hata - Broker

Question

Kafka'da, Apache Kafka web sitesindeki talimatları komut satırından takip ederek başlıklar oluşturmaya çalışıyorum. komutu çalışırken :

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) 

nasıl sorunu çözebilirsiniz:

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

şöyle hatası alıyorum? Buna başlamak için iyi belgeler var mı? Teşekkürler!

Answer 1

Aynı problemi yaşadım. Kılavuzun bu bölümünü takip etmelisiniz: Oluşturulmuş bir brokerim yoktu. 2 yeni broker oluşturun ve sorunu düzeltin.

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

Eğer bazı değişiklikler bununla yapılandırmak zorunda dosyalar olduğunu oluşturduktan sonra: "server-1.properties" olarak

:

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

(Port numarası gerekir bu adımları izleyin server.properties + 1'de sahip olduğunuz port numarası olsun. 9092 yazmam gerekiyordu, bu yüzden 9093 yazmalıyım)

"server-2.properties":

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

(Port numarası, sunucu-1'in yanında olmalıdır. Benim durumumda (9094)

Answer 2

Açıkça 0 komisyoncusu var diyor. Daha sonra, sunucu başlamamış gibi

Answer 3

görünüyor denemek konuyla

öldür süreci

sudo fuser -k 2181/tcp 

çalışma Yaupon

için günlükleri kontrol Apache Kafka öğretici üzerinde

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

tabanı tarafından bir komisyoncu başlayın

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

çalıştırın Kafka

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

Answer 4

olsam ben bu kodu denemek:

bin/kafka-topics.sh --create --zookeeper localhost: 2181/kafka --replication- Eğer direccion1:2181,direction2:2181,direction3:2181/kafka

için localhost:2181/kafka substitue gereken

Eğer Yaupon 3 düğümlerinde dağıtılacak bir küme kullanılarak halinde faktörü 1 --partitions 1 --topic testi

Answer 5

Aynı problemi yaşadım. Problemi çözüyorum. Bunun nedenini düşünüyorum çünkü arka plan başlangıcı yok. yüzden biz başlangıç ​​geçmiş oluşturdu 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

Sizin hayvan bakıcısı sizin Zookeepr konsolunda herhangi Kafka brokers.Try günlüğü göremeyen: konsolda bin/zkCli.sh -server localhost:2181 Çalıştır [zk: localhost:2181(CONNECTED) 2] ls /brokers/ids. Herhangi bir broker gösterilmemelidir. Tüm Kafka broker'larınızı yeniden başlatmanız ve kafka işlem günlüğünü kontrol etmeniz gerekiyor. Bazen, işlem çalışırken (ps -ef | grep kafka) gösterse bile, Zookeeper'ın göremediği için gerçekten tamamen başlatılmamış olabilir. Apache Kafka dağılımı 0.11.0 ile aynı sorunu vardı.