我只在configs中更改了日志和zookeeper数据的路径。
跑步管理员：
zookeeper-server-start.bat D:\__programs\kafka_2.12-2.1.0\config\zookeeper.properties运行Kafka：
kafka-server-start.bat D:\__programs\kafka_2.12-2.1.0\config\server.properties运行消费者：
kafka-console-consumer.bat -bootstrap-server localhost:2181 -topic mytopic运行生产者：
kafka-console-producer.bat -broker-list localhost:9092 -topic mytopic因此，消费者只能在与生产者位于同一端口（9092）上时获取消息。
有什么问题吗？
2条答案
按热度按时间t40tm48m1#
引导服务器和代理列表，都应该指向同一个
因为你正在制作localhost:9092，您应该在消费者中使用相同的方法，如下所示：
p、 通常是在美国
2181端口已分配给zookeeper进程。这里呢localhost:2181请找Zookeeper。31moq8wy2#
使用者和生产者是kafka服务器的客户机，因此它们都可以使用我们在server.properties文件中配置为客户机端口的相同端口。
端口配置在
config/server.properties包含以下任一参数的文件播发的.listeners
听众
取决于配置和协议消费者和生产者可以使用多个端口。您可以在这里找到代理参数的详细信息