尝试检索组详细信息时，Kafka消费者组不存在
Kafka消费者组是Kafka消息队列中的一个重要概念，用于将多个消费者组织在一起以协同消费消息。当尝试检索组详细信息时，如果Kafka消费者组不存在，可能有以下几种可能的原因和解决方法：
- 检查消费者组名称：首先，确保你输入的消费者组名称是正确的。消费者组名称是区分大小写的，因此请确保大小写匹配。
- 检查Kafka集群连接：确保你的应用程序或工具与正确的Kafka集群建立了连接。检查连接字符串、主机名、端口号等连接参数是否正确配置。
- 检查Kafka主题和分区：消费者组必须订阅一个或多个Kafka主题，并且每个主题可以有多个分区。确保你的消费者组订阅了正确的主题，并且主题中存在消息。
- 检查消费者组状态：如果消费者组处于非活动状态，可能会导致检索组详细信息失败。确保消费者组处于活动状态，并且至少有一个消费者正在运行。
- 检查Kafka版本兼容性：某些Kafka版本可能存在不同的行为或功能限制。确保你使用的Kafka版本与你的应用程序或工具兼容，并且支持检索组详细信息的功能。
如果以上步骤都没有解决问题，建议参考腾讯云的Kafka文档和相关资源，以获取更详细的信息和解决方案：
- 腾讯云Kafka产品介绍：https://cloud.tencent.com/product/ckafka
- 腾讯云Kafka文档：https://cloud.tencent.com/document/product/597
请注意，以上答案仅供参考，具体解决方法可能因实际情况而异。在遇到问题时，建议参考相关文档、咨询技术支持或寻求专业人士的帮助。
相关·内容
我正在尝试通过终端中的以下命令来描述kafka消费群： ./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group $GROUPID 我可以通过以下命令获取$GROUPID/kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --list 回应是： b'TestProcess' 但在尝试通过以下命令获取有关该组</
浏览 142提问于2019-05-26得票数 2
回答已采纳
1回答
我看到了一条kafka警告，警告我当前实例未订阅的主题。我们使用相同的kafka代理，每个开发人员都有自己的主题。但是，我们都使用属性文件中指定的相同默认groupID/clientid。2017-06-27T11:48:35.20-0400 [APP/PROC/WEB/0]OUT 2017-06-27 15:48:35,195 WARN [NetworkClient] - [kafka-coordinator-heartbeat-thread| ingestion-matching-kafk
浏览 19提问于2017-06-28得票数 0
回答已采纳
我使用和Kafka来使用Java来传递用例。我认为当您重新启动和Kafka服务器时，消费者组的详细信息将被删除。但他们没有。动物园管理员是否将消费者群体的详细信息保存在某种文件中？如果要重置使用者组，是否应该手动删除使用者组详细信息？
有人能向我澄清这一点吗？
浏览 1提问于2019-08-16得票数 0
回答已采纳
我知道Kafka Queue Partition中的所有消息(或偏移量)都有它的偏移量，它负责偏移量的顺序。但是，如果我有一个Kafka Consumer Group (或单个Kafka Consumer)，它正在读取特别是Kafka主题分区，那么它如何维护读取的偏移量消息，以及谁维护这个偏移量计数器？如果消费者宕机，那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18提问于2020-07-04得票数 1
回答已采纳
每个消费者属于不同的组id GROUP.1和GROUP.2
希望查看所有邮件的主题以及偏移量详细信息。.1‘不存在。需要在某个地方配置以持久保存使用者组详细信息，或者只有当具有给定组id的使用者当前正在运行时，命令才能工作，或者？我尝试了kafka-consumer-groups --zookeeper localhost:2181 --describe --group GROUP.1，但得到了同样的错误。也尝试过卡
浏览 1提问于2017-12-19得票数 3
回答已采纳
我只想要一个给定的groupID的消费者组滞后度量(或者它派生自、当前和最后的两个抵消项)。
我使用卡夫卡0.9+ (所以没有补偿在动物园管理员)，也可以使用更新的，如果需要。
浏览 1提问于2017-12-19得票数 0
我想检查手动分配到特定主题的消费者组的lag，这可能吗？我正在使用Kafka - 0.10.0.1运行sh kafka- .I -class.sh kafka.admin.ConsumerGroupCommand -new- consumer -describe-bootstrap-serverlocalhost:9092 -group测试，但它显示不存在任何组，所以我想知道当我们手动分配分区时，我们是否可以检查消费者的lag。
浏览 4提问于2018-01-17得票数 1
我注意到Consumer配置有两个ID。一个是group.id (强制)，另一个是consumer.id (非强制)。
浏览 2提问于2016-01-01得票数 45
我一直在尝试在java中以编程方式运行以下脚本，大多数情况下它们都可以工作，但对于某些情况，这个错误总是显示出来：“消费者组xyz不存在”。谁能解释一下为什么会发生这个错误，特别是当--list脚本中出现了consumer-group时。但此脚本会将使用者组列为活动的：那么，为什么它列出
浏览 0提问于2018-11-19得票数 2
我有python脚本，并且需要使用kafka1 broker集群检索一组从kafka主题读取的消费者的当前消费者组偏移量。这些是原生kafka消费者，将偏移量存储在kafka集群中，而不是zookeeper中。
脚本本身不需要使用任何消息，只需读取其他使用者的当前偏移量。我意识到使用kafka-consumer-groups.sh可以做到这一点，但理想情况下，我希望避免依赖外壳命令。我已经可以利用d
浏览 1提问于2018-03-12得票数 3
嗨，我正在寻找一个汇合cli命令来使用GetOffsetShell来获取最早和最新的偏移量，并获得消费者组的详细信息。查找以下kafka命令，的汇合cli命令/opt/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell \ --topic my_topic
浏览 9提问于2022-05-05得票数 0
1回答
我们有一个WebSocket服务器，它为每个WebSocket客户端创建一个单独的消费者组，这样每个WebSocket用户就可以相互独立地接收来自Kafka主题的更新。我们使用camel API来创建Kafka消费者(组)，它使用了Kafka原生Java API，所以这与Camel没有任何关系，但提到camel只是一个FYI。通过使用JMX和JMC监控，我们发现Kafka心跳线程被阻塞，并且对于每次新的WebSocket客户端加入时创建的每个新
浏览 1提问于2018-11-06得票数 1
我的kafka主题共有10条记录/消息和2个分区，每个分区有5条消息。我的使用者组有2个消费者，每个使用者已经分别从他们分配的分区中读取了5条消息。我停止了kafka使用者，并按照命令将使用者组偏移量重置为0。
.我的期望是，一旦我重新开始我的卡夫卡消费者，他们将开始阅读记录从偏移量0，即开始，但这没有发生，他们调查了他们的最后位置，即偏移量5。为什么是这样？然后，我必须让我的每个消费者，明确地寻求抵消0(开始)，以重新处理/读取记录从一开始。在以后
浏览 3提问于2019-06-27得票数 4
我已经为Kafka使用者编写了一个java代码，它使用executor服务，它将运行24/7，使用数据并处理它。但是在某些情况下，例如由于Kafka协调器代理节点崩溃，作业将失败--即消费者组将死亡，我将无法知道它，而java jar将运行但什么也不做。我想定期检查java代码中Kafka使用者的生动活泼。所以，如果卡夫卡的消费群体死了，我就能让它活下来，或者触发邮件，扼杀这份工作。
有人能提供这方面的任何投入吗。
浏览 0提问于2018-11-18得票数 0
回答已采纳
我正在寻找一个kafka rest api，将列出相同的细节 kafka-consumer-groups.sh --描述 将返回，基本上我正在尝试获取特定消费者组的每个分区的偏移量及其滞后的详细信息。
浏览 13提问于2019-05-27得票数 1
事实上，我正在寻找一种方法来获取存储在kafka brokers中的记录的详细信息，以供操作使用。我尝试过Kafka-consumer-groups.sh工具，但它只显示指定消费者组的信息，没有显示其状态的单个记录或一组记录的详细信息，例如“是否已消费”和“已消费的时间”。实际上，我的建议是，有时我的消费者不能正确地消费，而我的生产者已经成功发送了。所以我必须确定哪里出了问题。 有没有办法让我得到一些这样的记录信息？ 提前感谢！
浏览 11提问于2020-10-30得票数 0
我正在用Java创建一个新的Kafka消费者，就像这样(为简洁起见省略了一些代码) final Properties props = new Properties(); consumer.subscribe(Collections.singletonList("topicname")); 这也会自动创建使用者组，以防它还不存在。问题是，这个消费者群体的偏移量不是在主题的开头，而
浏览 114提问于2019-08-23得票数 0
回答已采纳
1回答
我有一个主题(我们称它为"my-custom- topic ")，它有6个分区，并且(实际上)其中有两个使用者属于同一个组。这个群是一个服务，我们称它为"myService“。所以，简而言之，我想让我在同一组中的所有服务接收那里的所有消息。(一次/消息) 我如何使用Kafka实现这一点？ 谢谢你对我的照顾。
浏览 25提问于2020-04-13得票数 0
回答已采纳
1回答
因此，我有一个消费者组在运行并侦听来自某个主题的消息。如何将更多的消费者实例添加到消费组中？(message) { }); 我尝试创建消费者并在选项中包含相同的组名， new kafka.Consumer( { topic: topicName} {
浏览 33提问于2020-10-07得票数 1
我有一个新的消费者列表(python消费者)。我可以使用以下命令检索组：我可以为每个主题获取它们所连接的主题bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --grou
浏览 9提问于2017-12-21得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
