有没有Python版本的kafka Describe Group可以从Kafka那里获得消费者的滞后？https://docs.confluent.io/platform/current/clients/consumer.html#describe-group
浏览 11提问于2021-09-03得票数 0
由于Kafka 0.10不再使用Zookeeper来存储lags，我现在如何检索它？有没有办法从消费者那里访问它？
浏览 0提问于2017-05-23得票数 6
回答已采纳
实例
consumer = KafkaConsumer("MyTopic", bootstrap_servers=self.kafka_server + ":" + str(self.kafka_port运行bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group MyTopic.group --describe<
浏览 0提问于2018-04-25得票数 4
回答已采纳
我有一个Streaming应用程序，它从Kafka主题中读取数据并将其放在HDFS上。我希望应用程序存储抵消读到__consumer_offsets主题的消息，以便在应用程序失败时开始阅读。Map( "enable.auto.commit" -> "true",
"group.id" -> &quo
浏览 0提问于2018-11-08得票数 0
1回答
我们正在使用kafka 2.12.XXXX，并且需要观察消费者在主题的所有分区上有多大的滞后。
在./kafka-consumer-groups.sh --describe中，滞后列的求和是它的精确表示吗？
浏览 5提问于2020-04-25得票数 2
我想知道kafka消费者的进度，也就是Lag。我知道下面的命令为我提供了lag和其他有价值的描述。bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper localhost:2182 --describe --groupDemoConsumer
bin/kafka-consumer-groups.sh --zookeeper local
浏览 0提问于2016-09-29得票数 0
2回答
is no longer part of the group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [task-thread-recovery-connector-oneof an active group (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) [task-thread-recovery-connect
浏览 13提问于2021-08-13得票数 2
回答已采纳
我正在寻找一个Kafka命令，它显示了所有的主题和分区的偏移。如果它是动态的，那就太完美了。现在，我正在使用java代码查看这些信息，但这非常不方便。
浏览 10提问于2015-06-25得票数 71
回答已采纳
7回答
我知道我可以使用包含在kafka-topics.sh目录中的bin\脚本来完成这个任务。一旦我有了这个列表，我需要每个主题的所有消费者。我无法在该目录中找到脚本，也无法在kafka-consumer-api库中找到允许我这样做的类。有办法做到这一点吗？
浏览 7提问于2015-09-21得票数 95
回答已采纳
kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group webapi-groupError: Consumer group 'web-api' does not exist.我也试过：
bin\kafka-consumer-groups.sh -bootstrap-server lo
浏览 2提问于2020-09-14得票数 2
从0.8.1.1版本开始，Kafka提供了在Kafka中存储偏移量的规定，而不是Zookeeper (参见)。
浏览 1提问于2015-12-01得票数 11
回答已采纳
kafka-consumer-groups.bat --bootstrap-server kafka-host:9092 --group my-group --reset-offsets --to-earliestFirstTopic 0 0但是再次运行命令：
kafka-consumer-groups.bat--b
浏览 2提问于2017-08-14得票数 47
回答已采纳
Kafka 8：
Group TopicPid Offset
浏览 2提问于2017-07-31得票数 6
2回答
我们注意到了一个奇怪的问题，我们的prod主题(6个分区)中，我们的使用者(dotnet核心，只有一个实例)只能从3个分区(0、1、3)中读取。这显然影响了应用程序的行为，因为使用者丢失了来自其他3个分区(2,4,5)的消息。我们能够验证主题配置没有任何问题。由于怀疑由于消息过期而导致的偏移提交问题，我们从主题中删除了所有消息(通过将保留期更改为少量)，但这并没有解决问题。我们尝试了几次重新启动消费者应用程序，每次分区分配保持不变(0,1,3)，这让我们相信其他分区有问题。我们正在考虑创造一个新的话题。想一想，我会把它张贴在这里，以检查我们是否遗漏了什么。如有任何投入，将不胜感激。谢谢。
浏览 5提问于2021-12-17得票数 1
需要为我们的应用程序(Kafka 0.10)生成Consumer Lag Metrics，其中偏移量存储在zookeeper中。寻找Java API或其他方法来获取存储在zookeeper中的偏移量。
浏览 39提问于2019-02-06得票数 0
1回答
/bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list此外，显式查询偏移量不会产生任何结果：No topic availablefor consumer group</em
浏览 2提问于2015-12-09得票数 7
回答已采纳
我目前正在使用Kadeck社区，有时在docker上使用命令来查看保存在kafka上的消息，但现在我正在测试事务语义，我只想查看提交的消息。我很难做到这一点。
浏览 0提问于2020-02-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
