如何获取、设置或重置Kafka Connect连接器/任务/接收器的偏移量？我可以使用运行kafka.admin.ConsumerGroupCommand的/usr/bin/kafka-consumer-groups工具来查看我所有常规Kafka消费者组的偏移量。但是，Kafka Connect任
浏览 1提问于2016-06-09得票数 16
回答已采纳
我知道我们可以获得消费者组的列表，然后将任何一个消费者组传递到特定的主题，以确定消费者偏移量。步骤1:使用以下命令获取消费组列表从获得的消费者列表中，选择一个消费者组步骤2
浏览 3提问于2018-10-09得票数 5
嗨，我正在寻找一个汇合cli命令来使用GetOffsetShell来获取最早和最新的偏移量，并获得消费者组的详细信息。查找以下kafka命令，的汇合cli命令/opt/kafka/bin/kafka-run-class.sh <em
浏览 9提问于2022-05-05得票数 0
1回答
当我使用kafka0.8.x时，我可以通过路径/consumers/group_id获得所有带有zookeeper的组列表，因为offsets将提交给0.8.x中的zookeeper。但在0.10.x版本中，提交给kafka broker的偏移量就像zookeeper中的路径/brokers/topics/__consumer_of
浏览 12提问于2017-01-16得票数 4
回答已采纳
为什么不推荐使用kafka-consumer中的zookeeper，为什么建议使用bootstrap服务器？bootstrap-server有什么优点？
浏览 0提问于2017-09-12得票数 36
回答已采纳
当消费者实例group.id在重启时更改时，是否会对kafka性能产生任何影响。较旧的group.id将会发生什么情况?它是否仍然存在于代理内存中，或者何时将被删除？假设我有1000+消费者实例，并且所有实例都在重启时动态分配group.id。
可以为{log.retention.ms'}提供什么列表值。可以设置为1ms吗？
浏览 8提问于2018-08-28得票数 0
回答已采纳
当我作为消费者连接时，其中一个代理成为组协调器。然后我杀了一个经纪人(否则它就死了)。如果我尝试立即重新连接到代理，则会出现协调程序不可用错误。Kafka是如何知道经纪人死了的，需要多长时间才能指派一个新的协调员？它是如何配置的？
这本应在文档中，但我找不到。
浏览 2提问于2017-08-08得票数 3
我希望我没有犯错，但我记得在Kafka文档中提到，使用高级API你不能从特定的偏移量开始读取消息，但它提到它会改变。我使用的是kafka 0.8.1.1。
提前谢谢。
浏览 0提问于2015-12-16得票数 7
回答已采纳
我有一个用例，其中我有两个消费者在不同的消费者组(cg1和cg2)中，订阅了具有4个分区的相同主题(主题A)。如果两个使用者从同一个分区读取数据，其中一个失败，而另一个提交了偏移量，会发生什么情况？
浏览 1提问于2020-03-06得票数 1
为什么消费者要连接到zookeeper来检索分区位置？kafka制作人必须连接到其中一个代理才能检索元数据。我的观点是，当每个代理都已经拥有所有必要的元数据来告诉生产者发送消息的位置时，zookeeper到底有什么用？难道经纪人不能把同样的信息发送给消费者吗？我可以理解为什么代理拥有元数据，这样就不必在每次向它们发送新消息时都与zookeeper建立连接。zookeeper有没有我
浏览 1提问于2015-01-13得票数 39
回答已采纳
我使用kafka_2.9.2-0.8.1.1和动物园管理员3.4.6。> bin/kafka-consumer-group
浏览 3提问于2015-03-24得票数 43
回答已采纳
我有python脚本，并且需要使用kafka1 broker集群检索一组从kafka主题读取的消费者的当前消费者组偏移量。这些是原生kafka消费者，将偏移量存储在kafka集群中，而不是zookeeper中。
脚本本身不需要使用任何消息，只需读取其他使用者的当前偏移量。我意识到使用<
浏览 1提问于2018-03-12得票数 3
旧版本建议消费者连接zookeeper，新版本建议连接broker？一个社区的网友回复我说，topic的offset老版本是ZK，新版本是Kafka本身。这是这个答案的答案吗？
浏览 0提问于2018-04-27得票数 1
我正在使用Kafka 0.9消费者API。我需要检查给定的使用者组和主题的当前使用者偏移量，并且还没有找到任何命令行工具来列出这些信息。我尝试了以下命令但这并没有列出消费者，即使我有
浏览 4提问于2016-05-13得票数 1
1回答
我正在运行一个消费者小组，听取项目和事情似乎是可行的。消费者团体的名称是default。令我惊讶的是，列出消费者群体给了我一个空列表：$$ ./bin/kafka-consumer-groups.sh
浏览 2提问于2015-12-09得票数 7
回答已采纳
这是一个基于Armando Ballaci提供的答案的"Where do zookeeper store Kafka cluster and related information?“的后续问题。现在很明显，消费者偏移量存储在Kafka集群中的一个名为__consumer_offsets的特殊主题中。很好，我只是想知道这些偏移量的检索是如何工作的。例如，
浏览 40提问于2020-07-05得票数 1
我正在使用ZookeeperdataVersion = 113179ephemeralOwner = 0x0numChildren = 0
o/p:
浏览 16提问于2017-02-25得票数 0
回答已采纳
1回答
我是Kafka的新手，我正在使用Kafka 1.0。
我使用pull模式阅读Kafka消息，也就是说，我会定期poll() kafka主题以获取新消息，但我没有将偏移量写回Kafka。我会问kafka如何知道我消耗了哪些偏移量，或者Kafka记住进度的机制是什么(Kafka偏移量)
浏览 9提问于2020-05-20得票数 1
回答已采纳
我刚接触Kafka，到目前为止，我对消费者的理解是，基本上有两种类型的实现。2)
高级抽象最重要的部分是当Kafka不关心处理偏移量时使用它，而简单的使用者对偏移量管理提供了更好的控制。让我困惑的是，如果我想在多线程环境中运行消费者，又想控制我使用的消费者组，这是
浏览 1提问于2013-08-01得票数 7
我有一个制作人，它发布关于“我的主题”的消息，非常好。我有两个不同的消费者群体中的两个消费者在收听这些信息。我按照下面的顺序开始了这两个消费者和制片人。1)启动“group1”组中的使用者1)启动生产者发布数百条消息/opt/kafka<
浏览 3提问于2016-11-16得票数 1
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
