腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
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,这个版本的
消费
组
管理似乎是个问题,如何
删除
不再使用的
消费
组
?你们打了补丁吗?
浏览 1244
提问于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
kafka
01.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
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
源码 kafka如何删除topic
Kafka消费者API
kafka如何彻底删除topic及数据
kafka消费者分组消费的再平衡策略
关于删除CDH中Kafka 的Topic 实战
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券