腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
与
特定
主题
相关
的
消费
群体
的
紧凑
显示
apache-kafka
、
command-line
client.properties --describe --all-groups --topic topic1 并得到了: 选项"topic“不能与选项"describe”一起使用 所以我想出了一个简单
的
补丁我是不是忽略了apache kafka CLI shell命令中已经提供
的
一些选项?
浏览 23
提问于2021-01-21
得票数 1
回答已采纳
1
回答
理解卡夫卡、
消费
者
群体
和
主题
apache-kafka
、
kafka-consumer-api
我试图理解卡夫卡
的
消费
群体
概念。所以我
的
问题是--
消费
者
群体
和话题之间
的
关系是什么?属于同一
消费
群体
的
两个不同
的
消费
者可以从不同
的
主题
中阅读吗?
浏览 4
提问于2016-09-22
得票数 3
回答已采纳
1
回答
如何通过SDK获取Kafka
消费
者
的
ip地址?
java
、
python
、
apache-kafka
我发现了如何获取
特定
主题
和
消费
群体
的
偏移和滞后,但如何获取
消费
群体
中
消费
者
的
ip地址? Java或Python SDK都可以。
浏览 32
提问于2021-07-09
得票数 0
回答已采纳
2
回答
如果我有相同
的
消费
群体
名称、不同
的
服务和不同
的
主题
,它会影响Kafka
的
性能还是再平衡
的
影响?
apache-kafka
、
kafka-consumer-api
对于每一项服务,我们都有一个
特定
的卡夫卡
主题
。在这里,每个服务都是不同
主题
的
使用者,但是它们
的
使用者组名称是相同
的
如果我们在同一组中添加另一个服务,它是否会
浏览 8
提问于2022-08-05
得票数 0
2
回答
卡夫卡多重
消费
群体
apache-kafka
、
kafka-consumer-api
我有多个
消费
者
群体
,每个
群体
有一个
消费
者。我
的
问题是,卡夫卡如何在多个
消费
者
群体
之间保持这种抵消
浏览 0
提问于2018-10-27
得票数 2
1
回答
是否有可能在普罗米修斯列出
与
卡夫卡出口商
的
消费
集团成员?
apache-kafka
、
prometheus
、
strimzi
卡夫卡出口商公开了"kafka_consumergroup_members“标准,它
显示
了每个
消费
者
群体
中有多少成员。然而,我想知道是否有可能列出每个
消费
群体
的
实际成员,类似于如何使用“-group-describe-members”选项
与
卡夫卡-
消费
者组。be shell脚本输出指定
群体
的
个人
消费
者。这是否有可能与卡夫卡出口商或任何其他卡夫卡
相关
的
出口
浏览 7
提问于2022-06-10
得票数 0
1
回答
不正确
的
Kafka跨
消费
群体
抵消
apache-kafka
、
kafka-consumer-api
我有一个由两个
消费
者
群体
使用
的
主题
。
主题
中有10条消息。应用1(
消费
者组1)已经完成了来自
主题
的
消息处理,当我描述kafka-使用者组(使用--group consumerGroup1)时,它正确地
显示
了当前偏移量=10和日志结束偏移量=10。现在我开始应用程序2(
消费
者组2),它正在使用相同
的
主题
。它不是在处理消息。当我描述卡夫卡-
消费
者
群体
(
浏览 0
提问于2019-01-14
得票数 1
回答已采纳
2
回答
如何使用Apache进行内容过滤?
java
、
apache-kafka
有一个生产者和两个
消费
者为这一
主题
。我需要做
的
是过滤由生产者产生
的
消息,根据它们
的
前缀。例如,如果消息以'a‘前缀开头,那么只有第一个使用者必须接受它。如果它以'b‘前缀开头,那么只有第二个
消费
者必须接受它。 我做了很多搜索,我发现
的
是过滤来自一个
主题
的
消息,然后在过滤后将它们发送到不同
的
主题
。但如前所述,我需要对一个
主题
进行过滤。
浏览 1
提问于2018-03-01
得票数 4
回答已采纳
1
回答
如果没有设置群组id,pyspark kafka如何知道它从哪里开始
消费
数据?
pyspark
、
apache-kafka
、
spark-streaming
我在没有指定kafka组id
的
情况下运行pyspark structured streaming,每次运行程序时,我发现记录器消息中
的
group.id总是被更改。我搞不懂,如果它改变了group.id,它怎么知道下一次从哪里开始
消费
,或者我应该手动设置kafka
的
偏移量?我怎么知道它自动生成
的
主题
id是否与我手动设置
的
其他
主题
id冲突?
浏览 2
提问于2020-01-08
得票数 0
1
回答
我正在阅读卡夫卡文档,并试图理解它
的
工作原理。
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我正在阅读卡夫卡
的
文件,并试图了解它
的
工作。这是关于
消费
者
的
。简单地说,
主题
被划分为分区
的
数目。有多个
消费
者
群体
,每个
群体
都有多个
消费
者实例。现在,我
的
问题是,每个分区是否向每个使用者组发送“相同”
的
消息,而这个消息又会给组内
的
特定
使用者实例?如果我遗漏了什么,请指点我。
浏览 2
提问于2018-12-13
得票数 0
回答已采纳
2
回答
决定
消费
者
群体
再平衡时间
的
因素是什么?
apache-kafka
我们最近在生产中看到了一些问题,当
消费
者离开组时,
消费
者组需要几分钟
的
时间来重新平衡。这个
特定
的
消费
者
群体
在任何给定
的
时间都有大约8-10个
消费
者成员,并且订阅了大约15个
主题
,每个
主题
有32个分区。 本质上是试图弄清楚我们应该做些什么,以便使再平衡花费更少
的
时间。(例如,我们是否尝试减少每个组
的
消费
者数量?每个
主题
的<
浏览 13
提问于2017-03-10
得票数 0
回答已采纳
4
回答
Kafka:生产者如何才能只发送给某个Consumer/GroupId
apache-kafka
自从我开始使用Kafka以来,我注意到Kafka正在广播每个
消费
者或
群体
的
消息。如何让生产者只将消息发送给某个
特定
的
消费
者?我说
的
是一个
主题
系统谢谢
浏览 1
提问于2018-01-04
得票数 0
1
回答
理解卡夫卡
消费
者在同一
消费
群体
中
的
再平衡,但订阅方式不同
apache-kafka
我需要澄清重新平衡如何影响同一
群体
的
消费
者,但他们订阅了Kafka 0.10.1中
的
不同
主题
regex。我查阅了卡夫卡文档并找到了一些<e
浏览 3
提问于2017-12-08
得票数 1
回答已采纳
1
回答
如何在
消费
者之间更换领导者?
java
、
apache-kafka
如果我有一个
主题
和多个具有相同groupId
的
消费
者,那么只有一个
消费
者应该收到消息(领导者)。我想选择哪个
消费
者将成为领导者,并在java中接收消息,但我不知道该怎么做。 这是我
的
一个
消费
者
的
代码。
浏览 1
提问于2019-08-22
得票数 0
1
回答
如果offsets.retention.minutes=2和cleanup.policy=compact,kafka会删除已提交
的
偏移量还是压缩它?
apache-kafka
我是卡夫卡
的
新手,但我理解卡夫卡在__consumer_offsets
主题
中存储
消费
者补偿,offsets.retention.minutes定义在此之后
消费
者补偿将被删除。但对我来说,__consumer_offsets
主题
有clean.policy=compact。当我取消__consumer_offsets
主题
时,请参阅下面的结果: Topic:__consumer_offsets PartitionCount:50复制因子:1 Configs:compression.type=p
浏览 2
提问于2021-04-14
得票数 2
回答已采纳
1
回答
如果服务对一个
主题
产生事件,则只有该服务必须
消费
来自另一个
主题
(Kafka)已处理事件
apache-kafka
我必须使用Kafka (Java技术栈)实现事件驱动
的
架构服务。我画了一个例子:假设我有3个外部生产者(Ms1、Ms2、Ms3),它们将事件发送到我
的
服务读取
的
一个
主题
中。收到事件后,我
的
服务处理一些业务逻辑,然后将事件推送到另一个
主题
。Ms1,Ms2,Ms3订阅这个话题,听一听新
的
内容。我
的
目标是:如果Ms1向topic-1发送事件,则只有Ms1必须接收来自topic-2
的
响应事件(尽管其他
消费
者也在监
浏览 1
提问于2021-05-02
得票数 0
1
回答
如何在合流kafka rest代理中访问
主题
的
最新偏移量来计算滞后
apache-kafka
、
kafka-rest
在合流
的
kafka rest代理中,我们可以得到
特定
消费
群体
的
最后提交偏移量,但是如何才能得到
主题
的
最新偏移量来计算滞后值。
浏览 2
提问于2019-07-11
得票数 0
1
回答
如何在Kafka服务器
的
同一
主题
上发布针对不同
消费
者
的
消息?
apache-kafka
对于我们
的
主题
,我们有多个
消费
者(单独
的
微服务),而我们在这个
主题
上发布
的
事件是为了单独
的
微服务,还是一次只针对一个
消费
者?我正在发布类似这样
的
记录-1为CG-A然后记录-2为CG-B,然后再次记录-3为CG-A。
浏览 1
提问于2022-10-11
得票数 0
1
回答
Kafka
消费
群体
的
活跃性空
主题
分区
apache-kafka
、
kafka-consumer-api
跟进这个 -我想知道
消费
者组之间
的
语义和抵消到期.总的来说,我很想知道,kafka协议是如何确定某个
特定
偏移量(对于
消费
者组、
主题
、分区组合)是否过期
的
?它是基于来自作为组协议一部分
的
使用者
的
定期提交,还是在所有使用者被视为死/关闭之后应用offset-tick?我认为,在处理不经常生成数据
的
主题
分区时,这可能会产生影响。在我
的
例子中,我们有一个
消费
者
群体</em
浏览 3
提问于2022-03-06
得票数 0
1
回答
如何在同一线程内成功地对第二个卡夫卡
消费
者进行调查?
java
、
apache-kafka
、
kafka-consumer-api
、
consumer
我有两个Kafka
消费
者,他们订阅不同
的
主题
,属于同一个
消费
群体
,具有不同
的
使用者in,运行在同一个线程中。他们正在按顺序执行投票,但在第一次投票结束后,第二次似乎陷入了投票。我试着将他们
与
不同
的
消费
者
群体
联系起来,这似乎很有效,但不幸
的
是,这对我来说不是一个可行
的
解决方案。我在“卡夫卡:权威指南”中找到了这个: 您不能在一个线程中拥有属于同一组
的
多个使用者,也不
浏览 3
提问于2019-12-09
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
电子邮件分割策略
龙年年货消费风向:国潮快速增长,95后成年货节主导者
特斯拉中国总裁证实将推出针对中国市场的更便宜车型
4种可以提高电子邮件选择表单有效性的营销策略
今天我们一起了解一下分类营销的依据!
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券