Błąd podczas tworzenia tematów Kafki - Współczynnik replikacji większy niż dostępne brokery

Question

Próbuję tworzyć tematy w Kafce, postępując zgodnie z przewodnikiem po witrynie Apache Kafka za pośrednictwem wiersza poleceń. Podczas uruchamiania polecenia:

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

pojawia się błąd w następujący sposób:

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) 

Jak mogę rozwiązać ten problem? Masz dobrą dokumentację, aby zacząć z tym? Dzięki!

Answer 1

Miałem ten sam problem. Musisz postępować zgodnie z tą częścią przewodnika: http://kafka.apache.org/documentation.html#quickstart_multibroker

Nie miałem żadnego utworzonego brokera. Utwórz 2 nowych brokerów, a rozwiążesz problem. Śledź ten kroki:

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

Po utworzeniu że pliki trzeba skonfigurować go z tym pewne zmiany:

W "server-1.properties":

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

(numer portu musi być numerem portu, który masz w swoim server.properties + 1. Miałem 9092, więc muszę napisać 9093)

W "server-2.properties":

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

(Numer portu musi znajdować się obok serwera-1. W moim przypadku 9094)

Answer 2

To wyraźnie mówi 0 broker jest dostępny. Zacznij brokera przez

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

bazy na samouczka Apache Kafka następnie spróbuj

Answer 3

Wygląda serwer nie rozpoczął, należy sprawdzić logi do publikacji

procesowego

Zabij

sudo fuser -k 2181/tcp 

run Heca

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

Run Kafka

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

Answer 4

Gdybym był tobą chciałbym wypróbować ten kod:

bin/kafka-topics.sh --create --zookeeper localhost: 2181/Kafka --replication- czynnik 1 --partitions 1 --topic Test

Jeśli używasz klaster gdzie zookeeper być dystrybuowane w 3 węzłach należy podstawniki, localhost:2181/kafka dla direccion1:2181,direction2:2181,direction3:2181/kafka

Answer 5

Miałem ten sam problem. Rozwiązuję problem. Myślę, że powodem tego jest brak uruchomienia w tle. tak, my neet tle rozruch

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

Twój Zookeeper jest w stanie dostrzec żadnych rejestrowanie Kafka brokers.Try w konsoli Zookeepr: bin/zkCli.sh -server localhost:2181 Uruchom [zk: localhost:2181(CONNECTED) 2] ls /brokers/ids na konsoli. To nie może pokazywać żadnych brokerów. Musisz zrestartować wszystkich brokerów Kafka i sprawdzić dziennik procesu kafka. Czasami, nawet jeśli proces pokazuje się jako działający (ps -ef | grep kafka), może nie zacząć tak naprawdę całkowicie, z powodu którego Zookeeper nie może go zobaczyć. Miałem ten sam problem z dystrybucją Apache Kafka 0.11.0.