腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(2879)
视频
沙龙
2
回答
向
同一
消费者
组
内
的
所有
订户
广播
消息
apache-kafka
我正在创建一个应用程序,我想在其中
向
同一
消费者
组
中
的
所有
订阅者(
消费者
)发布事件。但在许多地方,我发现Kafka
向
消费者
群体
广播
消息
。有没有办法做到这一点?
浏览 23
提问于2020-01-09
得票数 1
回答已采纳
1
回答
如何
向
卡夫卡
消费者
传达卡夫卡生产者是完整
的
?
apache-kafka
我有一个场景,其中生产者生成有限
的
数量
的
消息
,以及一
组
属于
消费者
组
的
消费者
使用和处理
消息
。 生产者更新外部db/
浏览 0
提问于2017-10-23
得票数 2
1
回答
如何在使用
同一
消费群体时对分布式
消息
进行kafka策略控制
apache-kafka
在使用
消费者
组
控制
消息
传递时,如何保证
同一
消费者
组
内
的
每个
消费者
都能轮询接收
消息
?另外,Kafka使用
的
默认策略是什么,似乎
所有
的
消息
都可以一直发送给一个
消费者
?
浏览 0
提问于2017-03-27
得票数 1
3
回答
芹菜
广播
与RabbitMQ扇形
rabbitmq
、
celery
它
的
配置乱七八糟,过于复杂,而且文档也不完整。 但是在芹菜中,
所有
的术语都是混乱
的
:在这里,您可以拥有一个,它
向
多个
消费者
发送
消息
:我甚至不明白芹菜<em
浏览 3
提问于2014-06-18
得票数 13
回答已采纳
3
回答
在ActiveMQ中
向
多个用户发送
消息
java
、
activemq
我是ActiveMQ
的
新手。我试图在activemq中实现生产者-
消费者
(发送者-接收者)。在我
的
代码中,我很容易通过ActiveMQ从单个生产者发送和接收
消息
到单个
消费者
。但是,问题是,我不能
向
同一
个生产者
的
多个
消费者
发送信息。 }; consumer.setMessageListener(listner);
浏览 7
提问于2014-08-29
得票数 2
回答已采纳
2
回答
使用来自主题
的
两个实例
java
、
apache-kafka
我已经部署了一个应用程序
的
两个实例。这两个应用程序运行相同
的
代码,并使用来自相同主题
的
代码。@KafkaKey String name, @Body @Nullable String someString) { } } 我有一个问题,即只有一个应用程序使用
消息
我已经尝试将
组
id和线程添加到KafkaListener。这似乎有时起作用,有时则不起作用。@KafkaListener(groupId="myGroup", threads=10) 让两个应用
浏览 18
提问于2020-08-24
得票数 1
回答已采纳
1
回答
消息
队列,可与Node.js一起使用,用于
向
多个客户端发送数据
node.js
、
amazon-web-services
、
redis
我有一个预订应用程序,其中3到4个设备是用于一个单一
的
位置。其中许多地方
的
互联网连通性很差,所以我们
的
想法是将数据存储在设备
的
本地存储中。我希望一个设备发送
的
数据转到服务器,然后发送到其他设备,以便它们在本地存储数据。 因此,在任何时候,
所有
客户端都将输入或发送其他设备
的
数据,以便它们不依赖于服务器而执行该数据。实现这类系统
的
最佳方法是什么?即使单个设备没有互联网连接,当互联网出现时,它也应该能够获取数据。我尝试了socket.io并读取aws<e
浏览 0
提问于2017-08-08
得票数 0
1
回答
同一
服务
的
不同节点可以充当
消费者
和生产者吗?
spring-boot
、
apache-kafka
我已经在三个不同
的
节点上部署了我
的
服务。 我有一个场景,用户做一些更新(例如添加新菜单),这将转到nosql数据库(Mongo)。我想使用Kafka,这样一个节点就会产生事件(添加到菜单中
的
新项目),
所有
其他节点都会消费。 我遇到
的
困难是
所有
节点都在运行相同
的
服务。 在卡夫卡中,一个人如何充当生产者,其他人如何充当
消费者
?
浏览 29
提问于2021-04-13
得票数 0
1
回答
如何从Kafka队列中读取?
publish-subscribe
、
apache-kafka
下面是如何使用Kafka作为发布订阅框架
的
一个很好
的
例子: 我正在拼命寻找一个类似的例子,展示如何使用kafka作为队列框架。这意味着一旦一个客户端检索到
消息
,任何其他客户端都不应该访问它。
浏览 0
提问于2014-11-11
得票数 0
3
回答
kafka分区
的
行为
apache-kafka
、
kafka-consumer-api
你能解释一下卡夫卡分区在这种情况下是如何工作
的
吗?分区1包含:1、4、7分区3包含:3、6、9 你能解释一下吗?我也想
消费者
团体可以解决这个问题,但不知道为什么。
浏览 7
提问于2017-07-03
得票数 1
回答已采纳
3
回答
多个Kafka
消费者
可以从分区中读取相同
的
消息
吗
apache-kafka
、
kafka-consumer-api
我们正计划编写一个Kafka
消费者
(Java),它读取Kafka队列来执行
消息
中
的
操作。请帮我理解一下。
浏览 5
提问于2016-02-23
得票数 75
1
回答
如何创建卡夫卡非持续性主题
apache-kafka
我计划在一个主题中使用多个
消费者
,但我不希望我
的
所有
消费者
都收到相同
的
信息。
浏览 2
提问于2016-01-18
得票数 0
回答已采纳
1
回答
使用两个独立
的
应用程序(storm和spark streaming)消费Kafka
消息
apache-kafka
、
spark-streaming
、
apache-nifi
我们使用Storm开发了一个摄取应用程序,它使用Kafka
消息
(一些时间序列传感器数据)并将这些
消息
保存到Cassandra中。我们使用Nifi工作流程来实现这一点。我现在要开发一个单独
的
星火流应用程序,它需要消费这些Kafka
消息
作为源。我想知道为什么当两个应用程序与一个Kafka Chanel交互时会出现问题?我是否应该将Nifi中
的
Kafka
消息
复制到另一个Chanel,以便我
的
Spark Streaming应用程序使用它们,但这是一个开销。
浏览 0
提问于2017-04-30
得票数 0
0
回答
有没有办法自动删除不包含任何
消费者
的
(服务总线事件中心)
的
消费者
组
azure
、
publish-subscribe
、
azureservicebus
、
azure-eventhub
、
azure-servicebus-topics
我有一个多实例应用程序,我使用服务总线事件集线器将一些
消息
放入其中,并将其
广播
到
所有
其他实例,将
消息
发送到
所有
实例
的
条件是每个实例都需要位于单独
的
消费者
组
中,否则一个实例将获取
消息
并将其删除,因此其他实例将不会获得该
消息
,因此我
的
解决方案是,首先每个实例创建自己
的
消费者
组
,然后侦听事件集线器,但这里
的
问题是,由
浏览 0
提问于2016-06-30
得票数 0
回答已采纳
1
回答
Facebook Messenger
广播
API可以针对多个标签吗?
facebook-graph-api
、
facebook-messenger
、
facebook-messenger-bot
关于
广播
API
的
问题。 我正在阅读Facebook
的
“目标
广播
消息
(测试版)”文档,我似乎不能在
广播
过程中设置多个标签,可以吗?因此,如果为“青少年”、“男性”、“在墨尔本”创建不同
的
标签,我不能使用一个标签对“墨尔本
的
男性青少年”运行
广播
API?如果这是不可能
的
,这是否意味着实现我想要
的
,我需要获得我
的
所有
订户
的
PSID (例
浏览 0
提问于2018-01-04
得票数 1
1
回答
Kafka
消费者
&分区查询
apache-kafka
、
kafka-consumer-api
我是卡夫卡
的
新手,很少读教程。我无法理解
消费者
和分区之间
的
关系。 我有一个主题,它有3个分区。我
浏览 3
提问于2016-01-08
得票数 0
4
回答
卡夫卡如何
向
许多
消费者
群体
广播
apache-kafka
我是卡夫卡
的
新手,我将非常感谢对下一个案例
的
澄清。 “我们
的
主题被划分为一
组
完全有序
的
分区,每个分区在任何给定
的
时间都由一个使用者使用。”基于上面的声明,如果很少
的
使用者
组
订阅了某个主题,并且生产者会将
消息
发布到这个主题中
的
特定分区,那么只有一个使用者可以提取
消息
。问题是,如果只有一个
消费者
能够传达特定
的
信
浏览 3
提问于2014-04-17
得票数 19
1
回答
应该为kafka
消费者
创建多少个分区?
apache-kafka
、
kafka-consumer-api
目前我只有一个主题分区和一个
消费者
。但是我
的
消费者
运行速度很慢,所以我想在
同一
主题中添加新
的
消费者
。 但同时,我也希望
所有
的
消费者
都能处理一
组
独占
的
消息
。我不能确定我应该创建多少个分区,以便在我想要增加吞吐量和处理独占
消息
时添加使用者。
浏览 0
提问于2017-11-14
得票数 0
1
回答
生产者-
消费者
的卡夫卡传播模型
apache-kafka
、
bigdata
、
kafka-consumer-api
我有一个主题A和10个不同
的
消费者
群体(比如A1,A2,A3 ....A10)。每个
消费者
组
的
消费速率是不同
的
(假设10 msg/s、30 msg/s、50 msg/s .......15 msg/s)。 为每个
组
广播
每个
消息
。我
的
A1最慢,A3最快。每个消费群体会得到
所有
的
消息
,还是会有
消息
丢弃,因为不同
的</em
浏览 0
提问于2018-02-22
得票数 0
1
回答
Apache :我们可以限制
消息
只被一个用户读取吗?
apache-kafka
、
messaging
、
kafka-consumer-api
我对Kafka很陌生,我尝试使用Apache Kafka实现
的
场景是:需求。 一次只能取一条指令进行处理。但是我
的
组织已经准备好了卡夫卡
的
设
浏览 3
提问于2016-11-21
得票数 6
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
【思唯网络】广播、组播、单播区别与联系
【思唯网络】 广播、组播、单播区别
广播、组播、单播区别与联系
美国付费电视家庭数量跌破75%
必知必会-使用kafka之前要掌握的知识
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券