2回答
如何删除kafka消费者群体(通过新的消费api创建)？
java、apache-kafka、kafka-consumer-api
我通过新的消费API创造了卡夫卡消费者。我们有一个使用者组，每个组中有一个使用者实例。Kafka脚本“kafka- old groups.sh”提供了删除用户的方法，但这只适用于运行命令的旧使用者组：给出
--删除：警告:组删除只
浏览 2提问于2016-06-10得票数 7
1回答
在Kafka中有没有办法检测到被删除的消费群？
apache-kafka
有一个Kafka服务器使用Kafka来存储消费者组的偏移量，我想知道__consumer-offsets topic是否会有一个针对已删除的消费者组的事件？或者我如何订阅此活动而不询问Kafka是否存在特定的消费群体
浏览 42提问于2020-09-12得票数 0
2回答
在删除10秒后，卡夫卡主题又重新出现了。
apache-kafka、kafka-consumer-api
我面临着卡夫卡主题删除的问题。
使用kafka创建/删除主题，并生成和消费消息。我已经尝试删除主题将被删除的主题，但一段时间后，比如说10秒，主题就会重新出现。已核对了消费者集团的抵消和滞后列为负数。docker run --net=host -rm confluentinc/cp-kafka:3.1.0 kafka-消费品组-动物园管理员本地主机:2181-描述-组</
浏览 2提问于2017-10-26得票数 4
1回答
如何删除卡夫卡“幽灵”消费者？
apache-kafka、apache-zookeeper
当我使用Kafka工具：https://www.kafkatool.com/时，我看到使用kafka-consumer-groups.sh时看不到的其他消费者组 我假设额外的消费者组来自Zookeeper，而kafka-consumer-groups.sh只显示它在代理上看到的内容。有没有办法删除这些“幽灵”群？它们没有被使用吗？我可以手动浏览zookeeper并删除这些节点吗？
浏览 31提问于2021-11-22得票数 1
5回答
如何删除Kafka消费者组重置偏移量？
apache-kafka、apache-zookeeper
我想删除一个Kakfa消费者组，这样当应用程序创建一个消费者并订阅一个主题时，它可以从主题数据的开头开始。这是使用当前最新的Confluent平台3.1.2的单节点vm开发，该平台使用Kafka 0.10.1.1。如果我使用“旧”消费者列出，我看不到我的消费者组(或任何其他消费者组)。sudo /usr/bin/kafka-consumer-groups --zooke
浏览 253提问于2017-03-03得票数 20
回答已采纳
1回答
Apache Kafka:对消费者组进行程序化监控
python、apache-kafka、kafka-consumer-api、confluent-platform、kafka-python
我想从Python应用程序中监控我的Kafka集群中的消费者组(基于Kafka的组，而不是ZK) (我愿意使用Kafka-python库和confluent Kafka客户端中的任何一个)。其目的是根据每个消费者组的滞后推出更多(或删除一些)消费者。
confluent Kafka admin API似乎没有Python选项来实现这一点。Burrow似乎是一种选择。
浏览 2提问于2018-08-13得票数 0
1回答
如何在不损失抵消的情况下将消费者从消费者群体中分离出来？
apache-kafka、logstash
我有一个logstash kafka消费小组订阅了将近20个主题，但是对于一个特别高优先级的kafka主题来说，它的处理效果并不好，所以我决定从消费者组中删除一个主题，并为高优先级的主题创建一个单独的消费组，但不幸的是，我失去了旧消费者组中的抵消项。不管怎么说，我是否可以开始新的logstash消费者组与上一个消费者组的初始抵消？
谢谢
浏览 0提问于2019-02-17得票数 0
回答已采纳
1回答
使用kafka- Consumer groups.sh脚本删除消费者组是删除消费者组元数据的安全方法吗？
apache-kafka、kafka-consumer-api
我使用多线程kafka使用者作为一个单独的60个分区kafka主题，每个使用者线程映射到每个分区。在消费完成后，使用KafkaConsumer.close()方法关闭每个使用者线程。在同一消费者不满意的情况下进行再消费期间(寻求开始是每个消费者的步骤)，1或2个使用者线程无法从它们分配的分区中消耗。如果提供了新的使用者组id，则不会出现此问题。因此，如果使用下面的脚本删除使用者组。bin/kafka-使用者
浏览 2提问于2019-10-25得票数 0
2回答
如何在使用新的消费者API时删除属于主题T的消费者组C
linux、apache-kafka
apache kafka的新版本在内部存储消费者组数据，而不是使用zookeeper你能告诉我：
如何在使用新的消费者API时删除属于主题T的消费者组C
浏览 6提问于2017-11-10得票数 0
1回答
当服务器重新启动后未使用消费者group.id时
apache-kafka
当消费者实例group.id在重启时更改时，是否会对kafka性能产生任何影响。较旧的group.id将会发生什么情况?它是否仍然存在于代理内存中，或者何时将被删除？假设我有1000+消费者实例，并且所有实例都在重启时动态分配group.id。
可以为{log.retention.ms'}提供什么列表值。可以设置为1ms吗？
浏览 8提问于2018-08-28得票数 0
回答已采纳
1回答
Kafka消费群体删除
apache-kafka、kafka-consumer-api
我在卡夫卡创建了大量的消费群体。当我检查状态时，它们中的大多数都是空状态，并且没有活动的使用者。自动删除消费者组在Kafka中是支持的，我们可以配置一个时间段来删除空的消费组吗？是否有支持自动删除空消费者组的特定版本？
浏览 2提问于2020-12-07得票数 4
回答已采纳
1回答
在动物园管理员和Kafka服务器重新启动后，Kafka消费者组仍然存在。
apache-kafka、apache-zookeeper
我使用和Kafka来使用Java来传递用例。我认为当您重新启动和Kafka服务器时，消费者组的详细信息将被删除。但他们没有。动物园管理员是否将消费者群体的详细信息保存在某种文件中？如果要重置使用者组，是否应该手动删除使用者组详细信息？
有人能向我澄清这一点吗？
浏览 1提问于2019-08-16得票数 0
回答已采纳
1回答
如何删除 CKafka 不再使用的消费组？
消息队列 CKafka 版、kafka
有个疑问，CKafka 使用了 Kafka 0.10，这个版本的消费组管理似乎是个问题，如何删除不再使用的消费组？你们打了补丁吗？
浏览 1338提问于2019-07-13
2回答
消费者集团必须有多大年龄才能被视为“老”
apache-kafka
"“指出：
但我在任何地方都找不到消费者集团应该有多大的历史。我应该等多久才能使用kafka-consumer-groups.sh工具删除新创建的消费者组？
浏览 3提问于2021-03-24得票数 1
回答已采纳
3回答
kafka自动提交-在c#.net中重置消费者组
kafka-consumer-api
我已经为它创建了主题和消费者组。我在启用自动提交的情况下启动了consumer。因为我的消费者现在很慢，所以有很多延迟，并且由于它的自动提交，偏移量被存储起来。因此，我想从最后一条消息开始，但kafka是根据存储的最后一个偏移量进行消费的。我甚至用自动提交和自动偏移量存储禁用启动了消费者，但因为它以前是存储的。
浏览 113提问于2021-07-20得票数 0
2回答
如何将卡夫卡消费者群体从一个特定的话题中删除？
apache-kafka、kafka-consumer-api、consumer
我更改了我的网络服务的消费者组id，听了卡夫卡的主题。现在，旧的组id仍然注册到主题中，但是没有使用该组id的使用者。因此，它是滞后的。如何从特定主题中删除特定的使用者组？我试过这个：
kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic--delete --group old-consumer-group --exec
浏览 2提问于2020-09-02得票数 10
回答已采纳
1回答
kafka-connect- elasticsearch :如何将elasticsearch与消费群同步？
elasticsearch、apache-kafka、apache-kafka-connect、confluent-platform
我想查询Kafka主题中的消息，但不是所有消息，不是从头开始。我只需要查看哪些消息尚未根据消费者组提交。所以，基本上我想要的是删除偏移量低于消费者组偏移量的单据。在这一点上，如果我使用elastic-connector，有没有办法或变通办法在消息被使用和提交后从弹性索引中删除文档？
或者，我应该使用Kafka Streams以及如何使用？
浏览 2提问于2021-05-08得票数 0
1回答
Kafka:谁负责维护消费者群体读取偏移量消息的上限？
apache-kafka、kafka-consumer-api
我知道Kafka Queue Partition中的所有消息(或偏移量)都有它的偏移量，它负责偏移量的顺序。但是，如果我有一个Kafka Consumer Group (或单个Kafka Consumer)，它正在读取特别是Kafka主题分区，那么它如何维护读取的偏移量消息，以及谁维护这个偏移量计数器？如果消费者宕机，那么新的消费者将如何开始读取下一个未读(或未确认)偏移量。
浏览 18提问于2020-07-04得票数 1
回答已采纳
4回答
移除动物园管理员中的卡夫卡消费者群体
apache-zookeeper、apache-kafka
我使用kafka_2.9.2-0.8.1.1和动物园管理员3.4.6。> bin/kafka-consumer-groups.sh --bootstrap-server localhost:90
浏览 3提问于2015-03-24得票数 43
回答已采纳
1回答
Kafka组清理
apache-kafka、kafka-consumer-api
我正在使用kafka (v0.10.1.1)和一些动态组(为每个新消费者创建新的group.id )。我必须重新检查/过滤过去的事件流，以获得一些标准，这意味着一段时间后，我有了许多组。有没有自动清理旧的未使用的组？
浏览 13提问于2017-02-21得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
腾讯会议
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号