Kafka QuickStart, advertised.host.name daje Kafkę.pospolite.LeaderNotAvailableException

Jestem w stanie uzyskać prostą Kafkę z jednym węzłem (kafka_2.11-0.8.2.1) działającą lokalnie na jednej maszynie linuksowej, ale kiedy próbuję uruchomić producenta zdalnie, dostaję kilka mylących błędów.

Podążam za przewodnikiem quickstart na http://kafka.apache.org/documentation.html#quickstart . zatrzymałem procesy Kafki i usunąłem wszystkie pliki zookeeper & karma w /tmp. Jestem na lokalnym 10.0.0.0 / 24 sieci nat-ed z zewnętrznym adresem IP, więc zmodyfikowałem server.properties aby powiedzieć zookeeper Jak nadawać mój adres zewnętrzny, zgodnie z https://medium.com/@thedude_rog/running-kafka-in-a-hybrid-cloud-environment-17a8f3cfc284:

advertised.host.name=MY.EXTERNAL.IP

Potem uruchamiam to:

$ bin/zookeeper-server-start.sh config/zookeeper.properties
--> ...
$ export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" # small test server!
$ bin/kafka-server-start.sh config/server.properties
--> ...

$ bin/kafka-topics.sh --create --zookeeper MY.EXTERNAL.IP:2181 --replication-factor 1 --partitions 1 --topic test123
--> Created topic "test123".
$ bin/kafka-topics.sh --list --zookeeper MY.EXTERNAL.IP:2181
--> test123

Jednak producent, który uruchamiam zdalnie, daje mi błędy:

$ bin/kafka-console-producer.sh --broker-list MY.EXTERNAL.IP:9092 --topic test123
--> [2015-06-16 14:41:19,757] WARN Property topic is not valid (kafka.utils.VerifiableProperties)
My Test Message
--> [2015-06-16 14:42:43,347] WARN Error while fetching metadata [{TopicMetadata for topic test123 -> 

Brak metadanych partycji dla tematu test123 ze względu na kafka.pospolite.LeaderNotAvailableException}] dla tematu [test123]: class kafka.pospolite.LeaderNotAvailableException (kafka.producent.Brokerpartioninfo) -- >(powtórzone kilka razy)

(wyłączyłem cały firewall, aby upewnić się, że to nie był problem.)

Błędy stdout w uruchomieniu karmy są powtarzane: [2015-06-16 20:42:42,768] INFO Closing socket connection to /MY.EXTERNAL.IP. (kafka.network.Processor)

I kontrolera.log daje mi to kilka razy:

java.nio.channels.ClosedChannelException
    at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
    at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:132)
    at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:131)
    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
[2015-06-16 20:44:08,128] INFO [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:MY.EXTERNAL.IP,port:9092 for sending state change requests (kafka.controller.RequestSendThread)
[2015-06-16 20:44:08,428] WARN [Controller-0-to-broker-0-send-thread], Controller 0 epoch 1 fails to send request Name:LeaderAndIsrRequest;Version:0;Controller:0;ControllerEpoch:1;CorrelationId:7;ClientId:id_0-host_null-port_9092;Leaders:id:0,host:MY.EXTERNAL.IP,port:9092;PartitionState:(test123,0) -> (LeaderAndIsrInfo:(Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:1),AllReplicas:0) to broker id:0,host:MY.EXTERNAL.IP,port:9092. Reconnecting to broker. (kafka.controller.RequestSendThread)

Prowadzenie tego wydaje się wskazywać, że jest lider w 0:

$ ./bin/kafka-topics.sh --zookeeper MY.EXTERNAL.IP:2181 --describe --topic test123
--> Topic:test123   PartitionCount:1    ReplicationFactor:1 Configs:
Topic: test123  Partition: 0    Leader: 0   Replicas: 0 Isr: 0

Przeskanowałem ten test i mój serwer.log wskazuje, że jest lider na 0:

...
[2015-06-16 21:58:04,498] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
[2015-06-16 21:58:04,642] INFO Registered broker 0 at path /brokers/ids/0 with address MY.EXTERNAL.IP:9092. (kafka.utils.ZkUtils$)
[2015-06-16 21:58:04,670] INFO [Kafka Server 0], started (kafka.server.KafkaServer)
[2015-06-16 21:58:04,736] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)

Widzę ten błąd w logach kiedy wysyłam wiadomość od producenta:

[2015-06-16 22:18:24,584] ERROR [KafkaApi-0] error when handling request Name: TopicMetadataRequest; Version: 0; CorrelationId: 7; ClientId: console-producer; Topics: test123 (kafka.server.KafkaApis)
kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0
    at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)

Zakładam, że oznacza to, że brokera nie można znaleźć z jakiegoś powodu? Nie wiem, co to znaczy...