腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
Kafka
主题
消息
数
我需要在一个卡夫卡
主题
存储的
消息
数量。这与是否有消费者消费了
消息
无关。kafka.tools.GetOffsetShell --broker-list localhost:9092,localhost:9093,localhost:9094 --topic test-topic 上面给出了
主题
的偏移量以上数据是否等于kafka topic当前存储的
消息
数
?
浏览 0
提问于2018-08-23
得票数 0
1
回答
ActiveMQ -咨询
消息
的TTL值是什么?
、
我需要知道咨询
消息
的TTL值是多少?我在我的咨询
主题
中有大约17000条
消息
入队,它显示了0条出队
消息
。我想摆脱这些信息。要做到这一点,可能的方法是什么?<deadLetterStrategy> </deadLetterStrategy> 如果没有订阅者订阅这些建议
主题
,那么这些
消息
是留在我想把这些
消息
从activr
浏览 0
提问于2018-08-08
得票数 0
3
回答
为什么KafkaUtils.createStream()的“
主题
”参数是映射而不是数组?
、
、
、
jssc, String zkQuorum, String groupId, java.util.Map<String,Integer> topics) 我知道字符串键是
主题
名。但是整数值呢?我该填什么?
浏览 1
提问于2019-06-05
得票数 4
回答已采纳
1
回答
使用Spark结构流时限制kafka批量大小
、
、
、
、
我们有一些历史数据在我们的
主题
中排队,我们不想在一个批次中处理所有这些数据,因为这很难做到(如果失败,它必须重新开始!)。 此外,了解如何控制批处理大小将对调优作业非常有帮助。理想情况下,我想知道像maxBatchSize和minBatchSize这样的配置,在那里我可以简单地设置我想要的记录
数
。
浏览 111
提问于2018-10-24
得票数 8
回答已采纳
4
回答
如何在Azure门户中查看servicebus
消息
、
我正在使用Azure服务总线
主题
机制。我已经将
消息
发送到
主题
,并希望在azure门户中查看所有发送到
主题
的
消息
。我可以看到
消息
计数,但希望看到实际的
消息
数
,而不是计数。 我该怎么做呢?
浏览 0
提问于2017-09-25
得票数 15
2
回答
活动MQ中挂起的
消息
和入队计数器之间的区别?
、
当一条
消息
被放到队列中时,这两个值应该匹配吗?
浏览 1
提问于2011-10-17
得票数 24
回答已采纳
2
回答
如何使用Java查找
主题
中显示的
消息
数量、为
主题
提供的分区
数
?
、
、
、
我有一个kafka
主题
,在这个
主题
中,我必须使用Java查找
主题
中显示的
消息
数量和出现在
主题
中的分区
数
浏览 5
提问于2021-07-28
得票数 0
回答已采纳
1
回答
Azure服务总线
主题
订阅
、
我有一个有多个订阅的
主题
。当其中一个订阅失败时,
消息
将被移动到DLQ。有没有办法找出哪个订阅失败了?如果再次处理相同的
消息
,那么如何确保已经处理该
消息
的订阅不再处理它?
浏览 6
提问于2022-10-17
得票数 0
1
回答
Kafka在设置retention.ms时不去掉数据
、
、
、
因此,当我寻找一种方法来计算
主题
中的
消息
时,这个方法很好 kafka-run-class kafka.tools.GetOffsetShell --broker-list broker1:9092,broker2配置更改为retention.ms=1000,甚至通过运行kafka-topics --describe --zookeeper zookeeper1:2181 --topic rev-dly-upd检查
主题
是否已配置时
浏览 177
提问于2018-07-31
得票数 1
回答已采纳
1
回答
当我们在运行时增加分区时,Kafka是如何保证
消息
顺序的?
、
、
我对kafka很陌生,当我阅读Kafka文档时,我意识到提供相同密钥的
消息
将被映射到相同的分区,以保证命令。这完全有道理。但是,我想知道如果我们在运行时增加
主题
分区的数量,是否会像以前一样将具有相同密钥的新
消息
散列到同一个分区(旧的)? 如果是这样的话,如果所有的
消息
都提供了键,那么它们都不会被映射到新的分区。如果没有,那么卡夫卡是如何保证顺序相同的
消息
的顺序的?
浏览 0
提问于2020-09-28
得票数 6
回答已采纳
2
回答
消息
到分区分配、排序和分区编号调整
正如我所理解的,如果我在我的
主题
中使用键控
消息
,kafka分区器将始终以相同的键向同一个分区发送
消息
,这将确保对特定
消息
集的排序。此外,默认分区程序将根据该特定
主题
可用的分区数量,最初作出向哪个分区发送
消息
的决定。有点像messageKeyHash % numberOfPartitions。我的问题是,如果我有一个关于5分区的
主题
,并发送具有键A并且都分配给分区0的3
消息
,然后我将该
主题
的分区
数
从5增加到5+x,那么
浏览 5
提问于2017-06-29
得票数 0
回答已采纳
1
回答
使用firebase auth的公共部门(gcp iam)
、
、
、
、
我想使用相同的令牌/ firebase uid从pubsub中提取通知,并将该firebase uid限制在特定的
主题
上,但是pubsub使用的是gcp的IAM,而不是防火墙身份验证。
浏览 0
提问于2018-04-03
得票数 1
回答已采纳
1
回答
>
主题
/
主题
/stats元素的size属性的含义是什么?
当我通过调用从ActiveMQ管理web界面检索
主题
列表时,如我得到一个xml文件,如下所示: <topics>
浏览 4
提问于2022-11-28
得票数 0
回答已采纳
1
回答
Kafka存储的
消息
多于产生的
消息
、
我有一个apache-kafka 0.8集群,设置如下-2)一个
主题
,10个分区,3个副本。但是,当我通过逐个关闭代理来测试设置时,我观察到消耗的
消息
数量多于生成的
消息
数量。 造成这种情况的可能原因是什么?
浏览 1
提问于2013-05-11
得票数 1
2
回答
如何获取
主题
中的JMS
消息
数
、
、
、
如何获取等待特定JMS
消息
订阅者使用的JMS
消息
数量?我使用
主题
模型(发布/订阅),而不是队列模型。我在互联网或文档中都找不到任何信息:( 我使用JBoss Messaging 1.4.4。
浏览 1
提问于2009-10-20
得票数 4
2
回答
Google
消息
传递的最大
主题
数
、
、
、
、
在iOS和Android上使用多个设备的用户 2)发送通知时,只需发送到某个
主题
即可。我的问题是。 是否有更好的方法
浏览 3
提问于2016-05-01
得票数 4
回答已采纳
6
回答
如何减少数字分区卡夫卡
主题
?
我在Kafka上创建了一个带有4个分区的
主题
。(设置默认的number.partition=4)。现在,我想将本
主题
的数字分区更改为3。 .
浏览 6
提问于2017-08-04
得票数 29
回答已采纳
1
回答
向多个用户发送Firesbase通知
、
、
、
、
我试图通过Firebase发送通知,但它不起作用。我只想用存储在MySQL中的Firebase ID发送给我的所有注册用户。下面是代码。 $path_to_fcm='https://fcm.googleapis.com/fcm/send'; $con = mysqli_connect('localhost
浏览 1
提问于2016-10-12
得票数 0
1
回答
谷歌酒吧/潜艇有像卡夫卡那样的分区概念吗?
如果n个订阅者为google pub/sub中的某个
主题
共享1个订阅,那么分区策略是什么? 是圆知更鸟吗?或者,如果没有再平衡,每个订阅者是否保证拥有一组密钥?
浏览 3
提问于2022-02-05
得票数 -1
回答已采纳
2
回答
一个MQTT代理可以处理多少个客户端?
每当发布者发布到某个
主题
时,所有订阅了该
主题
的订阅者都将通过MQTT代理获得
消息
。我想知道MQTT代理可以处理的最大客户端
数
。这有没有上限?
浏览 6
提问于2018-01-08
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
都说数仓是面向主题建设的,那数仓的主题和主题域又应该怎么划分呢?
南财主题库丨今日关注:东数西算主题
消息模型:主题和队列有什么区别?
观山湖区多处楼群点亮“数博会”主题灯光秀!
《TECT·数动文旅主题报告》发布 洞察数字文旅发展
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券