回答情况：
提问时间：
问题标签：
我认为主题可以被用作“真实事件广播”--每个消费者在特定事件发生时都会得到通知，但现在只有一个消费者消费一个事件，而其他消费者不知道创建的事件……
浏览 2修改于2020-04-30得票数 2
回答已采纳
将我的主脚本看作是一个不断广播各种事件发生的循环。例如：
FileChange: File at address XXX has changed.我打算做的是让我现在(以及以后)添加的其他应用程序，监听主要应用程序正在广播的内容，如果它与之相关(比如处理FileChange事件的脚本)，它们会收到消息并进行自己的处理。
浏览 1修改于2019-09-22得票数 0
是否有一些工具来播放StreamReader的内容
我试过制作一些天真的广播器，但在大型对象上失败了。我做错了什么？
浏览 4提问于2020-05-12得票数 2
回答已采纳
我想要做的是向所有应用程序实例广播一条消息，而不管它是哪个分区。
我听说我可以使用消费者团体来做这件事，但是我找不到任何关于它的教程。
浏览 4修改于2022-07-28得票数 2
回答已采纳
卡夫卡文件在“消费者立场”一段中说：
“我们的主题被划分为一组完全有序的分区，每个分区在任何给定的时间都由一个使用者使用。”问题是，如果只有一个消费者能够传达特定的信息，那么如何向许多消费者群体广播呢？
浏览 3提问于2014-04-17得票数 19
我想用芹菜从一个单一的生产者向多个消费者发送广播信息。令我困惑的是芹菜术语和底层运输RabbitMQ术语之间的差异。在RabbitMQ中，可以有一个和多个队列来广播消息：但是在芹菜中，所有的术语都是混乱的:在这里，您可以拥有一个，它向多个消费者发送消息：我甚至不明白芹菜广播队列是如何工作的，因为具有多个使用者的因此，在RabbitMQ中，如果多个消费者(即一个消费者池)连接到同一个队列，则只有一个使用者将接收和处理消息。
此外，芹菜文件的
浏览 3修改于2014-06-18得票数 13
回答已采纳
情况如下，有一个系统，有一个服务器，一个生产者和1.n消费者。
实际上，我在运行时使用了分流来解决这个问题。
浏览 1修改于2012-11-09得票数 2
回答已采纳
分片的数量以及消费者的数量不是常量。制作人有没有办法广播一个记录，比如发现分片并将记录放在每个分片上？
浏览 0修改于2016-01-20得票数 2
我正在写一个生产者/消费者程序。我有3个消费者从队列中读取数据，一个生产者在队列中写入数据。当生产者在队列中编写内容时，它会使用phtread_cond_broadcast进行广播。然后消费者醒来了，但我在我的程序中找到了一个模式。其中一个消费者总是比其他消费者先醒来，然后清空队列。我的问题是，广播每次以相同的顺序唤醒所有线程是正常的吗？pthread_mutex_lock(&mutex1);
if(/* write something *&
浏览 9修改于2013-03-26得票数 1
我在rabbitmq中读到了多个交换，如扇出等，用于组播、广播消息。
广播/多播的一种方式可以是在rabbitmq消息主体本身中具有标识符，而不是通过路由密钥/报头等来区分它。与通过NameValueCollection推送所有数据并决定单个消费者相比，使用routing-key/headers来决定消费者的好处是什么?要采取什么行动？我在这里看到的一个好处是，每个消费者都有一种类型的对象，看起来每个消费者只有一个责任。还有没有其他令人信服的事情选择这种方法
浏览 1提问于2017-05-03得票数 0
我有一个主题A和10个不同的消费者群体(比如A1，A2，A3 ....A10)。每个消费者组的消费速率是不同的(假设10 msg/s、30 msg/s、50 msg/s .......15 msg/s)。
为每个组广播每个消息。我的A1最慢，A3最快。每个消费群体会得到所有的消息，还是会有消息丢弃，因为不同的消费率。
浏览 0提问于2018-02-22得票数 0
我有一种情况，我需要广播一条消息，然后等待及时的响应。换句话说，广播消息期望来自所有订阅消费者的超时周期内的响应。使用直接交换是很简单的。我可以使用RPCClient来等待响应。然后实现我自己的消费者和消费者，消费者从相同的交换和发送者发送到相同的回复队列。它会起作用吗？
请给我建议。谢谢!
浏览 1提问于2015-06-19得票数 2
我正在创建一个应用程序，我想在其中向同一消费者组中的所有订阅者(消费者)发布事件。但在许多地方，我发现Kafka向消费者群体广播消息。有没有办法做到这一点？
浏览 23提问于2020-01-09得票数 1
回答已采纳
我想使用RabbitMQ不断地将对象的状态广播给任何可能正在收听的消费者。我想设置它，这样当消费者订阅时，它将获得最后一个可用状态……这个是可能的吗？
浏览 1提问于2012-05-14得票数 4
回答已采纳
自从我开始使用Kafka以来，我注意到Kafka正在广播每个消费者或群体的消息。如何让生产者只将消息发送给某个特定的消费者？我说的是一个主题系统谢谢
浏览 1提问于2018-01-04得票数 0
消费者代码如下：from kafka.consumer import SimpleConsumer
在卡夫卡()的文档中写着：
怎样才能使新的信息被一个消费者读取，而不是通过广播呢？
浏览 0提问于2014-02-16得票数 2
回答已采纳
我有一个场景，其中生产者生成有限的数量的消息，以及一组属于消费者组的消费者使用和处理消息。
卡夫卡是否有任何内在特征来实现这一目标？
浏览 0提问于2017-10-23得票数 2
例如，在电话层将消息发送出设备之前，我是否可以监听来自应用层的广播(例如，消息)并消费消息？
浏览 1提问于2011-06-23得票数 1
回答已采纳
2回答
我需要一些介于广播频道的多播功能(这样消费者就不会为事件而争斗)和常规频道的缓存/挂起功能(这样消费者就可以接收一些积压的事件)之间的东西。
浏览 20提问于2019-10-09得票数 2
回答已采纳
如果使用者对来自主题(offset = OFFSET_END)的消息是最新的，那么消费者如何执行它的阻塞poll()如果这有关系的话，我正在使用汇合python客户端。
谢谢!
浏览 4修改于2019-10-25得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号