腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
用于
Kafka
消息
队列
的Python库-用于发送请求(客户端)并回复响应(服务器端)
、
为
Kafka
消息
队列
需要一个适当的python库-客户机端和服务器端示例,以及python中的示例。 将结果反馈给客户。
浏览 10
提问于2022-01-24
得票数 0
1
回答
当
队列
达到一定数量的
消息
时,
Kafka
会通知吗?
我计划使用
Kafka
在
队列
中存储
消息
,并在特定
队列
中的
消息
数量达到某个限制(例如1000)时获取
消息
。 有没有办法让
Kafka
服务器在
队列
达到极限时通知消费者?
浏览 0
提问于2014-05-27
得票数 1
2
回答
Apache Camel vs Apache
Kafka
、
、
、
据我所知,Apache
Kafka
是异步
消息
传递平台,而Apache Camel是实现企业集成模式的平台。 那么,Apache Camel和Apache
Kafka
的实际区别是什么呢?我们计划用Apache Camel实现系统,这相对容易,但我们的客户想要Apache
Kafka
而不是rational。选择Apache
Kafka
实现
消息
队列
功能有什么好处,Apache Camel也可以实现?我担心
Kafka
只会给项目带来不必要的开销。我们是在比较苹果
浏览 4
提问于2018-01-30
得票数 16
2
回答
我可以在Rest WEBSERVICE中使用
Kafka
队列
吗
、
现在我在想,我是否可以将请求存储在一个
队列
中,这样服务器就可以拉取请求并为该请求提供服务,并处理挑选时间问题。 现在我在想,
Kafka
对此是否有帮助,如果是,我可以从哪里开始。
浏览 0
提问于2017-04-07
得票数 4
1
回答
测试
Kafka
主题设置是否正确
我们的应用程序使用各种类型的
队列
。每次启动使用
队列
的应用程序之前,都会自动进行预检查,将样本
消息
写入所需的
队列
,并读取(即删除)该
消息
,以确认
队列
是否设置正确。 现在我们也使用
Kafka
。但在
Kafka
中,我们不能通过写入和读取带有主题的
消息
来进行预检查,因为
消息
不能在启动实际应用程序之前删除,这有点“污染”主题。在
Kafka
中有没有其他自动化的方式、API或命令行脚本来实现这一点?
Kafk
浏览 8
提问于2017-12-28
得票数 1
1
回答
Apache
kafka
偏移量在apache storm拓扑中提交
、
我正在设计一个apache storm拓扑(使用streamparse),它使用一个spout (apache
kafka
spout)和一个并行大于1的螺栓构建,可以批量读取
kafka
spout中的
消息
并将
消息
持久化到mysql表中当螺栓在mysql上插入失败时,我不会在
kafka
中提交偏移量,但一些
消息
已经在spout发送到螺栓的
消息
队
浏览 2
提问于2019-01-31
得票数 0
1
回答
我希望使用sparkstreaming保持作业运行
、
、
、
有没有可能让流作业一直运行?大约24小时后,它发出此错误并停止处理。我不太确定该怎么处理这件事。 21/01/01 00:03:30 WARN KafkaOffsetReader [stream execution thread for [id =17bf-45aa-a9cd-2f77ec14df61, runId = 43c1-a932-d9f790996a6e]]: Retrying to fetch latest offsets because of incorrect offsets 21/01/01 07:17:04 ERROR RawSocketSender [MdsLogger
浏览 20
提问于2021-04-09
得票数 0
回答已采纳
1
回答
当
kafka
实例被弹出时,如果
消息
在
消息
队列
中,
消息
会发生什么情况?
如果由于不可纠正硬件问题,
kafka
的请求
队列
排队,如果这一次,我们关闭/退回
kafka
代理,那么追随者将会发生什么?
队列
中的
消息
会发生什么?
kafka
.network:type=RequestChannel,name=RequestQueueSize Size of the request queue.A congested request queue will not be able to process incoming or outgoing requests 根据我从
浏览 45
提问于2021-08-25
得票数 0
1
回答
Kafka
:如何删除
队列
中所有我无权访问的
消息
?
我有一个
kafka
消息
队列
,我无法访问
kafka
安装的bin文件夹。 在这种情况下,是否可以删除
队列
中的所有
消息
?创建一个客户端并仅使用所有
消息
是否足够?
浏览 0
提问于2020-11-13
得票数 0
0
回答
kafka
把
消息
放回
队列
,可以吗?
、
我想知道是否可以将来自
kafka
消费者的
消息
放回
队列
中?最佳实践是什么?我的案例是:谢谢。
浏览 6
提问于2016-07-20
得票数 2
回答已采纳
1
回答
使用Apache
Kafka
代替SQS
、
、
、
我有一个应用程序,它使用AWS SQS和Lambda来处理推入
队列
的
消息
。Lambda会继续轮询
队列
,当出现新
消息
时,它会处理该
消息
。 在这种情况下,是否可以在AWS上使用
Kafka
替换SQS。换句话说,我们可以使用
Kafka
作为这个用例的
队列
吗?
浏览 20
提问于2020-07-16
得票数 0
2
回答
如何删除/清除卡夫卡排队的
消息
而不删除主题
有没有办法删除
队列
消息
而不删除
Kafka
主题?我知道有几种方法: 重置保留时间$ ./bin/
kafka
-topics.sh --zookeeper localhost:2181 --alter --topic MyTopic --config retention.ms=1000删除卡夫卡文件$ rm -rf /data/
kafka
-logs/<topic/Par
浏览 5
提问于2017-09-14
得票数 39
回答已采纳
1
回答
Apache
Kafka
节点js和点对点工作流
、
、
因此,我刚刚开始探索
kafka
(使用节点js),并且使用
kafka
节点模块与
kafka
交互。我刚刚编写了一些测试消费者代码(见下文)。当我运行这个使用者代码的多个实例并将新
消息
推送到一个主题时,所有使用者的实例都会提取
消息</em
浏览 0
提问于2017-06-10
得票数 0
回答已采纳
3
回答
Python:如何为单元测试模拟
kafka
主题?
、
、
、
我们有一个
消息
调度器,它在将
消息
属性放到
Kafka
主题
队列
中之前,会根据
消息
属性生成一个散列键。最终,无论用于模拟
Kafka
队列
的是什么,都应该以与本地集群相同的方式工作-即,为主题
队列
提供关键字插入。 有这样的工具吗?
浏览 1
提问于2016-10-31
得票数 10
回答已采纳
2
回答
读取后Apache手动删除
队列
、
、
我对
kafka
非常陌生,我注意到在一个消费者阅读了
队列
消息
之后,
队列
消息
似乎已经消失了。如果这是主题
队列
的正常行为..。是否有一种方法可以避免在阅读后自动删除主题
消息
?顺便说一句,这是我运行的启动本地
kafka
服务器的命令:卡
浏览 3
提问于2018-04-16
得票数 0
3
回答
使用IBM集成总线从Apache
Kafka
到IBM MQ的
消息
、
、
从IIBv10.0.0.7开始,我可以使用KafkaConsumer节点来接收发布在
Kafka
主题上的
消息
。我需要一些客户端,这将能够接收来自
Kafka
的
消息
,并将其放在IBM MQ中,并从IBM MQ获得
消息
,并发布到
Kafka
主题中。我已经有IIB和IBM MQ了。
Kafka
是集成系统之一的
消息
系统。是否可以使用KafkaConsumer节点和MQOutput节点将收到的来自
Kafka
的
消息
放入IBM
队列
浏览 0
提问于2017-10-01
得票数 1
1
回答
Camel JMS组件多线程
、
、
、
、
我有一个spring boot应用程序,使用Camel的jmsComponent处理来自多个Solace
队列
的
消息
。我为每个
队列
连接定义了一个Camel route,并定义了一个将
消息
转换为json的Camel Processor。有大量来自
队列
的
消息
,而我的程序无法跟上速度。throws Exception {
浏览 22
提问于2020-07-21
得票数 1
1
回答
Apache
kafka
:如何通过编程找到
队列
和发布/订阅之间的差异
、
、
如何以编程的方式了解
队列
和发布/订阅之间的区别,我的项目需要
队列
的概念。你能提供一个用java编写的
队列
程序示例吗?
浏览 0
提问于2016-08-09
得票数 1
1
回答
如何识别
KAFKA
主题消费后未处理的
消息
、
、
据我所知,
kafka
source通过streamname-
kafka
-offsets主题维护MyCompositeModule使用的
消息
的偏移量(这是一个接收器,因为它是通过'module compose此外,当我从
kafka
源推送
消息
时,
消息
在redis传输中排队,然后模块从这个
队列
中获取它们。如果
kafka
消费者模块开始消费
kafka
redis
队列
中的1000条
消息
-复合模块在收到
浏览 0
提问于2015-12-18
得票数 1
1
回答
简单拉
消息
队列
、
、
我探索过一些不同的
消息
队列
,比如
Kafka
,Kestrel,等等.我在寻找具有拉力功能的东西。我想知道
Kafka
还是Kestrel是否支持这种功能
浏览 0
提问于2013-08-29
得票数 4
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列之 Kafka
分布式消息队列Kafka学习笔记
Kafka消息队列学习进阶(二)-项目实战
消息队列中间件(三)Kafka 入门指南
Kafka消息队列学习进阶(三)-原理概念介绍篇
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券