无法使用kafka-console-consumer.sh消费消息
我已经建立了一个由3个节点组成的AWS集群。我修改了节点的/etc/hosts文件，看起来像这样
172.31.9.2kafka1172.31.9.2zookeeper1172.31.19.230kafka2172.31.19.230zookeeper2172.31.35.20kafka3172.31.35.20zookeeper3
当我从其中一个节点运行命令时
bin/kafka-console-consumer.sh --bootstrap-server kafka1：9092 --topic first_topic --from-start
它可以工作，但是当我用ip替换主机名并用下面的命令运行它时
bin/kafka-console-consumer.sh --bootstrap-server 172.31.9.2：9092 --topic first_topic --从头
它不起作用。我需要更改某些配置吗？
共有1个答案
在服务器的“listeners”配置项中指定主机名时。属性，使用0.0.0.0作为主机以使kafka更允许地接受连接。这里有一些相关的文档，我认为推荐的访问方法是像现在一样锁定它，并按主机名访问代理。
-
因为我是新的Kafka，所以我能够从文件中读取记录，并通过生产者将消息发送到Kafka主题，但不能通过消费者消费相同的主题。 注意：您可以从任何文本文件中读取数据，我使用的是Kafka2.11-0.9。0.0版本 这是我的密码： 下面是输出：
-
我用本地安装的Confluent4.0.0尝试了官方模式-注册表-汇合示例（Consumer/Producer），它可以在发送post请求和在listener接收时发送“Sensor”avro消息，但当我使用Confluent4.0.0附带的kafka-avro-console-consumer工具查看发送的avro消息时，该工具引发了以下错误(a)。我还尝试使用kafka-avro-consol
-
我有一个简单的Kafka设置。生成器正在以较高的速率向单个分区生成具有单个主题的消息。单个使用者正在使用来自此分区的消息。在此过程中，使用者可能会多次暂停处理消息。停顿可以持续几分钟。生产者停止产生消息后，所有排队的消息都将由使用者处理。生产者产生的消息似乎不会立即被消费者看到。我使用的是Kafka0.10.1.0。这里会发生什么？下面是使用消息的代码部分： 代理上的所有配置都保留为kafka默认
-
我在ActiveMQ中使用异步消息使用者。我的制作人工作正常，向队列发送消息。现在，我的异步消息消费者正在等待调用onMessage（），但这从未发生过。因此，问题是： 异步使用者不会使用消息 ActiveMQ日志的快照还显示了许多刚刚堆积在挂起状态中的消息： 我想不出问题到底出在哪里。 计数： toPageIn 78 只是不断增加，信息仍然无法传递给消费者。 是服务器端问题还是客户端问题？
-
在我们的spring boot应用程序中，我们注意到Kafka消费者偶尔会在prod env中随机消费两次消息。我们在PCF中部署了6个实例和6个分区。我们发现在同一主题中收到两次具有相同偏移量和分区的消息，这会导致重复，对我们来说是业务关键。我们在非生产环境中没有注意到这一点，在非生产环境中很难复制。我们最近转向Kafka，但我们无法找到根本问题。 我们使用的是spring cloud stre
-
我正在尝试让 kafka 消费者获取在 Java 中生成并发布到主题的消息。我的消费者如下。 consumer.java 当我运行上面的代码时，我在控制台中什么也看不到，屏幕后面的java producer程序正在‘AATest’主题下不断地发布数据。另外，在动物园管理员控制台中，当我尝试运行上面的consumer.java时，我得到了以下行 此外，当我运行指向 AATest 主题的单独控制台使用