动物园管理员在执行 kafka-console-consumer.sh 时不是公认的选项

2022-08-31 15:45:06

我正在学习如何在这个网站链接上使用Kafka(除了我在zookeeper中使用端口2182),但它显示:

动物园管理员不是公认的选择

执行后:

sudo ./bin/kafka-console-consumer.sh --topic test --zookeeper localhost:2182

如何解决?

环境:

kafka_2.11-2.1.0
zookeeper-3.4.10

答案 1

我在快速入门中找到答案:

选项已弃用,请改用。zookeeper--bootstrap-server

现在它的工作原理:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

答案 2

对于窗户

开始动物园管理员

C:\kafka-2.12>.\bin\windows\zookeeper-server-start.bat .\config\server.properties

启动卡夫卡经纪人

C:\kafka-2.12>.\bin\windows\kafka-server-start.bat .\config\server.properties

创建主题

C:\kafka-2.12\bin\windows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

启动生产者

C:\kafka-2.12\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic test

创建消费者

C:\kafka-2.12\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

使用复制因子为 1 的多分区创建主题

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --topic first_topic --create --partitions 3 --replication-factor 1

获取在系统中创建的主题列表

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --list

获取在系统中创建的主题的说明

C:\kafka-2.12\bin\windows>kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

删除在系统中创建的主题测试

C:\kafka-2.12\bin\windows>kafka-run-class.bat kafka.admin.TopicCommand --delete --topic test --zookeeper localhost:2181

从系统(版本>2.0)中创建的主题测试开始读取消息

C:\kafka-2.12\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginn

推荐