Kafka Bootstrap-服务器与Kafka中的zookeeper-Console-Consumer
我正在尝试用3个代理&Zookeeper来测试运行一个单独的Kafka节点。我希望使用控制台工具进行测试。我是这样管理制作人的：
kafka-console-producer --broker-list localhost:9092,localhost:9093,localhost:9094 --topic testTopic
然后我以这样的方式运行消费者：
kafka-console-consumer --zookeeper localhost:2181 --topic testTopic --from-beginning
我可以在生产者中输入消息，并在消费者中看到它们，这是预期的。但是，当我使用bootstrap-server运行消费者的更新版本时，我什么也得不到。例如：
kafka-console-consumer --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --topic testTopic --from-beginning
当我有一个代理在端口9092上运行时，这工作得很好，所以我彻底搞糊涂了。有没有办法让我看到zookeeper作为引导服务器提供了什么？引导服务器与代理列表不同吗？Kafka用Scala2.11编译。
共有1个答案
我不知道出了什么问题。很可能是我把Kafaka或者动物园管理员置于一种怪异的状态。在删除每个代理的log.dir中的主题和/brokers/topics中的zookeeper主题，然后重新创建该主题之后，Kafka consumer的行为与预期的一样。
-
到目前为止，在运行Spring Boot应用程序之前，我已经从命令行启动了zookeeper和kafka server，但现在我需要直接从代码启动它们。 首先，我已经尝试在main方法中使用ProcessBuilder： 但这似乎不起作用，因为控制台上没有打印任何内容，过了一段时间，应用程序抛出一个TimeoutException。 第二，我想让kafka服务器在Zookeeper启动后运行；一个
-
服务发现是基于微服务架构的关键原则之一。尝试配置每个客户端或某种形式的约定可能非常困难，可以非常脆弱。策展人（一个用于Zookeeper的java库）通过服务发现扩展提供服务发现服务。Spring Cloud Zookeeper利用此扩展功能进行服务注册和发现。 如何激活 包括对org.springframework.cloud:spring-cloud-starter-zookeeper-dis
-
我是Kafka的初学者 1/我下载了Kafka的1.0.0版本 2/I更改了bith server.properties和zookeeper.properties中的数据目录位置属性 你能帮帮我吗？
-
本文向大家介绍ZooKeeper 集群中的服务器状态?相关面试题，主要包含被问及ZooKeeper 集群中的服务器状态?时的应答技巧和注意事项，需要的朋友参考一下 LOOKING ：寻找 Leader。 LEADING ：Leader 状态，对应的节点为 Leader。 FOLLOWING ：Follower 状态，对应的节点为 Follower。 OBSERVING ：Observer 状态，对
-
我有一个独立的Kafka经纪人，我试图配置SASL。配置如下。我试图在经纪人身上设置SASL_PLAIN身份验证。 我的理解是，这与听众有关。名称服务器中的配置。属性，我不需要jaas文件。但我已经尝试过一种方法，看看这是否是一种更好的方法。 我对这些命令中的每一个都进行了实验，但都产生了相同的异常。 显示的异常为： KafkaServer启动期间出现致命错误。准备关机。。。找不到“KafkaSe
-
我读过消费控制台中的线程boostrap-server vs zookeeper，但我不清楚这一点。 我的疑问是，假设我们有zookeeper在localhost:2181上运行，三个代理服务器在localhost:9092、localhost:9093、localhost:9094上运行，我们有一个主题my_topic与分区3和replication1，主题由代理共享，因为它有三个分区。 在Ap