Kafka消费者连接检查
我想在远程位置检查Kafka消费者的连接。
可以确定是否将使用者分配给分区。
在远程位置，我可以从Kafka代理获得有关该主题的详细信息。
但是消费者能否保证消费者能够收到消费者与主题分区匹配的消息？
共有1个答案
您可以使用Kafka Rest Proxy来确定分区是否已分配给使用者。
我认为，KafkaRest代理具有您所需的所有功能。
-
我刚接触Kafka，很少阅读教程。我无法理解使用者和分区之间的关系。 请回答我下面的问题。 > 消费者是否由ZK分配到单个分区，如果是，如果生产者将消息发送到不同的分区，那么其他分区的消费者将如何使用该消息？ 我有一个主题，它有3个分区。我发布消息，它会转到P0。我有5个消费者（不同的消费者群体）。所有消费者都会阅读P0的信息吗？若我增加了许多消费者，他们会从相同的P0中阅读信息吗？如果所有消费者
-
我是Kafka的新手。我在网上读了很多关于Kafka制作人和Kafka消费者的说明。我成功地实现了前者，它可以向Kafka集群发送消息。然而，我没有完成后一个。请帮我解决这个问题。我看到我的问题像StackOverflow上的一些帖子，但我想更清楚地描述一下。我在虚拟盒子的Ubuntu服务器上运行Kafka和Zookeeper。使用1个Kafka集群和1个Zookeeper集群的最简单配置（几乎是
-
Flink kafka消费者有两种类型的消费者，例如： 这两个消费者层次结构扩展了相同的类。我想知道维护编号类背后的设计决策是什么？我们什么时候应该使用其中一种？ 我注意到带有数字后缀的类有更多的特性（例如ratelimiting）。 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
我不知道是怎么回事，我的java客户机消费者用@KafkaListener注释后没有收到任何消息。当我通过命令行创建消费者时，它可以工作。同样，Producer也能按预期工作（同样在java中）。有人能帮我理解这种行为吗？ application.yml 生产者配置： 消费者配置： 制作人 Spring控制器： 这是我的控制台输出，正如您所看到的，它发送一条消息，但该方法不接收任何内容。如果我没有
-
我是Kafka的新手，我有一个使用Java Apache Camel库实现的Kafka消费者。我发现的问题是-消费者花了很长的时间(>15分钟）来处理很少的消息-这对于我们的用例来说是很好的。 需要一些配置帮助，因为相同的消息会在15分钟后重新发送，如果在15分钟内没有处理（我相信线程控制不会返回）。我想这可能是默认间隔，不确定这是哪一个属性。 那么，我必须在哪里修复配置 生产者级别，以便它不重新