Кафка тема не создается

Я устанавливал kafka в Quickstart Cloudera VM, используя следующий ссылка

но когда я запускаю команду ниже

kafka-topics --zookeeper quickstart.cloudera:2181 --create --topic test --partitions 1 --replication-factor 1

Я получаю следующую ошибку

19/09/21 11:28:36 INFO zookeeper.ClientCnxn: Session establishment complete on server quickstart.cloudera/10.0.2.15:2181, sessionid = 0x16d54d21037009d, negotiated timeout = 30000
19/09/21 11:28:38 INFO zookeeper.ZooKeeperClient: [ZooKeeperClient] Connected.
Error while executing topic command : Replication factor: 1 larger than available brokers: 0.
19/09/21 11:28:40 ERROR admin.TopicCommand$: org.apache.kafka.common.errors.InvalidReplicationFactorException: Replication factor: 1 larger than available brokers: 0.

Я попытался решить эту проблему из здесь . но при выполнении команды ниже

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

но получаю ошибку.

19/09/21 11:54:42 ERROR quorum.QuorumPeerMain: Invalid config, exiting abnormally
org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException: Error processing config/zookeeper.properties
at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:131)
at org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:106)
at org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:79)
Caused by: java.lang.IllegalArgumentException: config/zookeeper.properties file is missing
at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:115)
... 2 more
Invalid config, exiting abnormally

Любое лидерство ценится.

На самом деле я хочу подключить кафку к искре. Если есть другой способ сделать это. это тоже нормально.


person Ayush Goyal    schedule 21.09.2019    source источник
comment
1) config/zookeeper.properties file is missing ... Какие файлы есть в папке config? 2) Похоже, Кафка не работает. Как вы это начали? 3) Вам действительно нужна виртуальная машина? Spark, Kafka и Zookeeper работают вне одного   -  person OneCricketeer    schedule 22.09.2019
comment
cloudera_generation, cloudera_metadata, kafka-client.conf, tools-log4j.properties   -  person Ayush Goyal    schedule 22.09.2019
comment
вышеуказанные файлы присутствуют. Я устанавливал с помощью посылок. Так что не знаю, почему этого файла нет. Мне нужно работать на HDFS, Spark, kafka. Поэтому я хочу использовать это. Я также пытался установить kafka в свои окна, но получил ту же ошибку.   -  person Ayush Goyal    schedule 22.09.2019
comment
Все эти файлы должны находиться в папке конфигурации github.com/apache/kafka/tree/ магистраль/конфигурация   -  person OneCricketeer    schedule 22.09.2019
comment
Как я должен получить эти файлы там? Любое предложение?   -  person Ayush Goyal    schedule 22.09.2019
comment
Скопировать текст файла github в файл на виртуальной машине?   -  person OneCricketeer    schedule 22.09.2019
comment
Я также пытаюсь установить Kafka в Windows. В папке config все эти файлы есть, но это дает мне ошибку ниже   -  person Ayush Goyal    schedule 22.09.2019
comment
Ошибка при выполнении команды темы: Коэффициент репликации: на 1 больше, чем у доступных посредников: 0. [2019-09-22 15:08:13,903] ОШИБКА org.apache.kafka.common.errors.InvalidReplicationFactorException: Коэффициент репликации: на 1 больше, чем у доступных посредников : 0. (kafka.admin.TopicCommand$)   -  person Ayush Goyal    schedule 22.09.2019
comment
Вы тоже работаете с kafka-server-start? Насколько я могу судить, вы только запустили Zookeeper.   -  person OneCricketeer    schedule 22.09.2019