腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
Kafka
主题
消息
数
apache-kafka
我需要在一个卡夫卡
主题
存储的
消息
数量。这与是否有消费者消费了
消息
无关。kafka.tools.GetOffsetShell --broker-list localhost:9092,localhost:9093,localhost:9094 --topic test-topic 上面给出了
主题
的偏移量以上数据是否等于kafka topic当前存储的
消息
数
?
浏览 0
提问于2018-08-23
得票数 0
2
回答
提交前对变量进行preg_match检查
php
、
if-statement
、
preg-match
在提交表格之前,我需要确认一些检查:上面的语句检查$phone不小于11位
数
。$phone必须是11位
数
(不多,
不减
)。我该怎么做?
浏览 6
提问于2015-03-15
得票数 0
回答已采纳
1
回答
ActiveMQ -咨询
消息
的TTL值是什么?
activemq
、
dead-letter
我需要知道咨询
消息
的TTL值是多少?我在我的咨询
主题
中有大约17000条
消息
入队,它显示了0条出队
消息
。我想摆脱这些信息。要做到这一点,可能的方法是什么?<deadLetterStrategy> </deadLetterStrategy> 如果没有订阅者订阅这些建议
主题
,那么这些
消息
是留在我想把这些
消息
从activr
浏览 0
提问于2018-08-08
得票数 0
3
回答
为什么KafkaUtils.createStream()的“
主题
”参数是映射而不是数组?
java
、
apache-spark
、
apache-kafka
、
spark-streaming
jssc, String zkQuorum, String groupId, java.util.Map<String,Integer> topics) 我知道字符串键是
主题
名。但是整数值呢?我该填什么?
浏览 1
提问于2019-06-05
得票数 4
回答已采纳
1
回答
使用Spark结构流时限制kafka批量大小
scala
、
apache-spark
、
apache-kafka
、
spark-streaming
、
spark-structured-streaming
我们有一些历史数据在我们的
主题
中排队,我们不想在一个批次中处理所有这些数据,因为这很难做到(如果失败,它必须重新开始!)。 此外,了解如何控制批处理大小将对调优作业非常有帮助。理想情况下,我想知道像maxBatchSize和minBatchSize这样的配置,在那里我可以简单地设置我想要的记录
数
。
浏览 111
提问于2018-10-24
得票数 8
回答已采纳
4
回答
如何在Azure门户中查看servicebus
消息
azure
、
azureservicebus
我正在使用Azure服务总线
主题
机制。我已经将
消息
发送到
主题
,并希望在azure门户中查看所有发送到
主题
的
消息
。我可以看到
消息
计数,但希望看到实际的
消息
数
,而不是计数。 我该怎么做呢?
浏览 0
提问于2017-09-25
得票数 15
2
回答
活动MQ中挂起的
消息
和入队计数器之间的区别?
activemq
、
messages
当一条
消息
被放到队列中时,这两个值应该匹配吗?
浏览 1
提问于2011-10-17
得票数 24
回答已采纳
2
回答
如何使用Java查找
主题
中显示的
消息
数量、为
主题
提供的分区
数
?
java
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我有一个kafka
主题
,在这个
主题
中,我必须使用Java查找
主题
中显示的
消息
数量和出现在
主题
中的分区
数
浏览 5
提问于2021-07-28
得票数 0
回答已采纳
1
回答
Azure服务总线
主题
订阅
azure-servicebus-topics
、
azure-servicebus-subscriptions
我有一个有多个订阅的
主题
。当其中一个订阅失败时,
消息
将被移动到DLQ。有没有办法找出哪个订阅失败了?如果再次处理相同的
消息
,那么如何确保已经处理该
消息
的订阅不再处理它?
浏览 6
提问于2022-10-17
得票数 0
1
回答
Kafka在设置retention.ms时不去掉数据
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
kafka-topic
因此,当我寻找一种方法来计算
主题
中的
消息
时,这个方法很好 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
回答
使用HoloEveryWhere减小apk的大小
android-widget
、
apk
、
android-holo-everywhere
我在我的项目中使用HoloEveryWhere。但我对最后一轮比赛的规模并不满意。任何人都可以提供关于如何缩小大小或只包含特定样式的特定指南,这些样式将在整个应用程序范围内有效。
浏览 2
提问于2013-03-03
得票数 0
6
回答
如何用最少的步骤使序列成为不递减的序列?
algorithm
、
sorting
、
dynamic-programming
在每一步中,它被允许将任意
数
的值增加1或减少1。游戏的目标是使序列以最小的步
数
不减
少。
浏览 2
提问于2011-04-27
得票数 8
1
回答
当我们在运行时增加分区时,Kafka是如何保证
消息
顺序的?
apache-kafka
、
kafka-topic
、
kafka-partition
我对kafka很陌生,当我阅读Kafka文档时,我意识到提供相同密钥的
消息
将被映射到相同的分区,以保证命令。这完全有道理。但是,我想知道如果我们在运行时增加
主题
分区的数量,是否会像以前一样将具有相同密钥的新
消息
散列到同一个分区(旧的)? 如果是这样的话,如果所有的
消息
都提供了键,那么它们都不会被映射到新的分区。如果没有,那么卡夫卡是如何保证顺序相同的
消息
的顺序的?
浏览 0
提问于2020-09-28
得票数 6
回答已采纳
1
回答
oracle正则表达式从右限制字符位置
regex
、
oracle
我无法继续前进,花了所有的时间做谷歌,但没有找到一个解决方案,我的以下查询。
浏览 5
提问于2015-06-05
得票数 0
回答已采纳
2
回答
消息
到分区分配、排序和分区编号调整
apache-kafka
正如我所理解的,如果我在我的
主题
中使用键控
消息
,kafka分区器将始终以相同的键向同一个分区发送
消息
,这将确保对特定
消息
集的排序。此外,默认分区程序将根据该特定
主题
可用的分区数量,最初作出向哪个分区发送
消息
的决定。有点像messageKeyHash % numberOfPartitions。我的问题是,如果我有一个关于5分区的
主题
,并发送具有键A并且都分配给分区0的3
消息
,然后我将该
主题
的分区
数
从5增加到5+x,那么
浏览 5
提问于2017-06-29
得票数 0
回答已采纳
1
回答
使用firebase auth的公共部门(gcp iam)
firebase
、
google-cloud-platform
、
firebase-authentication
、
google-cloud-pubsub
、
google-cloud-iam
我想使用相同的令牌/ firebase uid从pubsub中提取通知,并将该firebase uid限制在特定的
主题
上,但是pubsub使用的是gcp的IAM,而不是防火墙身份验证。
浏览 0
提问于2018-04-03
得票数 1
回答已采纳
1
回答
>
主题
/
主题
/stats元素的size属性的含义是什么?
activemq
当我通过调用从ActiveMQ管理web界面检索
主题
列表时,如我得到一个xml文件,如下所示: <topics>
浏览 4
提问于2022-11-28
得票数 0
回答已采纳
1
回答
Kafka存储的
消息
多于产生的
消息
java
、
apache-kafka
我有一个apache-kafka 0.8集群,设置如下-2)一个
主题
,10个分区,3个副本。但是,当我通过逐个关闭代理来测试设置时,我观察到消耗的
消息
数量多于生成的
消息
数量。 造成这种情况的可能原因是什么?
浏览 1
提问于2013-05-11
得票数 1
2
回答
如何获取
主题
中的JMS
消息
数
jboss
、
jms
、
messaging
、
subscriber
如何获取等待特定JMS
消息
订阅者使用的JMS
消息
数量?我使用
主题
模型(发布/订阅),而不是队列模型。我在互联网或文档中都找不到任何信息:( 我使用JBoss Messaging 1.4.4。
浏览 1
提问于2009-10-20
得票数 4
1
回答
uWebSockets并发会话
javascript
、
c++
、
asynchronous
、
libuv
、
uwebsockets
为了简单起见,让我们假设我的服务器上只运行了一个uWebSockets实例:{ bool logged_in = false;}; .ws<UserData>( { [](auto *ws, auto
浏览 6
提问于2020-05-30
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
都说数仓是面向主题建设的,那数仓的主题和主题域又应该怎么划分呢?
南财主题库丨今日关注:东数西算主题
消息模型:主题和队列有什么区别?
观山湖区多处楼群点亮“数博会”主题灯光秀!
《TECT·数动文旅主题报告》发布 洞察数字文旅发展
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券