Я пытаюсь создать контейнер Kafka в Google Kubernetes Engine, следуя этой ссылке.
https://dzone.com/articles/ultimate-guide-to-installing-kafka-docker-on-kuber
Пока я вижу Kafka-брокера и Zookeepar при запуске и запуске, операция записи на любой топи c завершается с ошибкой ниже.
bash-4.4# kafka-console-producer.sh --topic test1 --broker-list PLAINTEXT://34.70.196.179:9092
>hello
[2020-03-20 11:55:24,806] WARN [Producer clientId=console-producer] Error while fetching metadata
with correlation id 34 : {test1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Я описал темы и обнаружил, что лидеры не были избраны.
bash-4.4# kafka-topics.sh --describe --zookeeper zoo1:2181 --topic test
Topic: test PartitionCount: 2 ReplicationFactor: 1 Configs:
Topic: test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: test Partition: 1 Leader: 0 Replicas: 0 Isr: 0
bash-4.4# kafka-topics.sh --describe --zookeeper zoo1:2181 --topic admintome-test
Topic: admintome-test PartitionCount: 1 ReplicationFactor: 1 Configs:
Topic: admintome-test Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Какие-либо предложения? Заранее спасибо.