Kafka用户订阅主题，但不消费消息，也不出现在用户组列表中
Kafka使用者(org.apache.Kafka:kafka-clients:2.3.0)应该使用来自一个分区的主题的消息。
该服务记录使用者订阅，但它不使用消息，也不使用官方的Apache工具kafka-consumer-groups.sh显示在使用者组列表中。
2020-06-15 11:50:50.308 [main] INFO o.a.k.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-1, groupId=my-groupid] Subscribed to topic(s): my-topic
共有1个答案
问题是动物园管理员的配置。它被配置在处理3个Kafka代理的3个独立节点中，而不是在分布式系统中。
-
拥有发布者和N个消费者，如果消费者使用，那么他们将错过订阅主题之前发布到主题的所有消息...众所周知，使用的消费者不会重播订阅主题之前存在的消息... 所以我需要： null 我想使用者必须检查现有消息的主题，如果有消息就使用它们，然后启动使用。对我来说这是最好的方法...
-
我正在使用Kafka0.8.0并尝试实现下面提到的场景。 JCA API（充当生产者并将数据发送到）------>消费者------>HBase 当我使用JCA客户端获取数据时，我会立即将每个消息发送给消费者。例如，一旦生产者发送第1号消息，我就想从消费者那里获取相同的消息并将其“放入”HBase。但是我的消费者在一些随机的n条消息之后开始获取消息。我想让生产者和消费者同步，这样他们两个开始一起工
-
我有一个简单的java制作人，如下所示 我正在尝试读取如下数据 但消费者并没有从Kafka那里读到任何信息。如果我在处添加以下内容 然后消费者开始从题目开始阅读。但是每次消费者重新启动时，它都从我不想要的主题开始读取消息。如果我在启动消费程序时添加了以下配置 然后，它从主题中读取消息，但是如果消费者在处理所有消息之前重新启动，那么它不会读取未处理的消息。 有人可以让我知道出了什么问题，我该如何解决
-
我有两个组id相同的消费者服务器订阅了相同的主题。kafka服务器仅使用一个分区运行。据我所知，消息应该在这两个消费者服务器中随机使用。但现在似乎总是同一个消费者服务器A消费消息，另一个不消费消息。如果我停止消费者服务器A，另一个将正常工作。我所期望的是，他们可以随机消费信息。
-
我有一个调查多个主题的消费者。对于这个问题，我限制了每个主题一个分区。假设当消费者开始轮询时，每个主题都有一些数据。阅读的顺序是什么？ 是循环赛吗？它是从第一个读到下一个吗？我使用进行轮询。
-
因为我是新的Kafka，所以我能够从文件中读取记录，并通过生产者将消息发送到Kafka主题，但不能通过消费者消费相同的主题。 注意：您可以从任何文本文件中读取数据，我使用的是Kafka2.11-0.9。0.0版本 这是我的密码： 下面是输出：