3回答
我有一个主题，在一个Kafka集群中有5个分区和5个代理。我在Partition 1(假设是P1 )中保持消息顺序，.I希望将P1的消息广播给10个消费者。所以我的问题是:这10个消费者如何与主题分区p1交互。
浏览 0提问于2018-08-06得票数 0
1回答
我有一个用例，需要向水平可伸缩、无状态的应用程序集群中的所有节点广播消息，我正在考虑使用Kafka。因为集群的每个节点都需要接收主题中的所有消息，所以集群的每个节点都需要有自己的使用者组。为了用Kafka实现这一点，我将在从主题消费时使用使用者进程的instanceId (或某些唯一标识符)作为使用者组id。这将推高消费群体的数量。随着重新部署的完成，新的使用者组将开始。，在任何给定的时间，我最多能拥有多少活跃的消费者群体？在其他瓶颈(如带宽等)出现之前，消费<
浏览 5提问于2021-07-15得票数 0
我的Kafka消费者的主要责任是抓取我们在Kafka中的任何日志/记录/消息，并将它们存储到数据库中。假设我的消费者正在积极消费dogs和cats主题，并且一切正常，现在有一种新的动物进入商店，并且在Kafka集群中生成了一个新的主题。如何通知我的消费者添加了新的主题？1.)生产者向消费者发送一个http请求，并让消费者知道生产者将要创建一个新的主题，因此消费者可以相应地采取行动。这种方法的问题是，存在竞争条件。<
浏览 2提问于2017-10-11得票数 0
是否有任何选项或配置可以方便单个Kafka消费者同时消费来自两个不同集群的消息？在创建生产者和消费者时，我提到这两个集群都是逗号分隔的。我一直在观察消费者只使用来自单个集群的消息。请参见下面的说明:消费者集群配置为侦听集群: C1 -1: Zookeeper-1 with Broker-1 Cluster-2: Zookeeper-2 with Broker-2
我正在寻找一种解决方案，其中
浏览 0提问于2019-03-18得票数 0
3回答
我想用芹菜从一个单一的生产者向多个消费者发送广播信息。令我困惑的是芹菜术语和底层运输RabbitMQ术语之间的差异。在RabbitMQ中，可以有一个和多个队列来广播消息：但是在芹菜中，所有的术语都是混乱的:在这里，您可以拥有一个，它向多个消费者发送消息：我甚至不明白芹菜广播队列是如何工作的，因为具有多个使用者的因此，在RabbitMQ中，如果多个消费者(即一个消费者池)连接到同一个队列，则只有一个使用者将接收<
浏览 3提问于2014-06-18得票数 13
回答已采纳
我有几个队列，我需要对其中一个队列执行以下操作:生产者应该向这个队列发送消息，但是所有的消费者都应该收到它。因此，如果队列中有5个spring侦听器，那么每个侦听器都应该接收消息，而不是生产者。我这样做是因为我有一个tomcat集群和rabbitmq异步消息，如果我从工作人员那里得到响应，我不知道如何将它分配到正确的tomcat节点。因此，我决定广播所有工人对所有tomcat节点的答复。每个tomcat集群节点侦听相同的输出队列。然后，如果它是一个正确的tomcat实例，它将被处理，所有其他副本将丢失，而
浏览 1提问于2015-12-18得票数 0
回答已采纳
2回答
模块聚类和JMS
、、、
然后，由于HA和工作负载的原因，我需要集群这个模块，我可能会使用Terracotta+Hibernate来集群我的实体。在这里，我从阅读问题中了解到，如果我只是在N不同的JVMs上启动我的模块，那么将创建N、不同的订阅者、和，队列中的每条消息都将到达N订阅者。
浏览 4提问于2010-08-17得票数 2
回答已采纳
1回答
我有一个主题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
对于集群中的所有节点，运行相同的生产者代码和使用者代码有什么坏处吗？如果集群中有8个节点(8个消费者、8个kafka代理和8个生产者)，那么集群中会有8个生产者同时运行吗？是否有一种方法可以修改集群，使每次只运行一个生产者？
浏览 0提问于2019-01-08得票数 0
回答已采纳
1回答
我想问问消费者群体，但是在云之间..。生产者:经纪人集群:B、C、消费者:d、E、F我想问，我们能用同一个组配置云D和云E吗？因为当我开始我的消费脚本(我使用kafka/laravel)时，我只运行了kafka : my，然后是kafka消费者运行。
当我使用多个云时，我需要在每个云中运行每个脚本。我不知道我的代理发生了什么，代理集群能够了解
浏览 3提问于2022-01-10得票数 0
我正在寻找java客户端(Kafka Consumer)来使用来自多个代理的消息。敬请指教创建Topic时，复制因子为2，分区为3。{ int numP
浏览 4提问于2017-03-28得票数 2
我们已经设置了MirrorMaker来跨两个Kafka集群复制消息。我们还在mirror maker的消费者属性中设置了exclude.internal.topic=false，以复制内部主题。我假设这也将复制__consumer_offset topic，这将反过来同步辅助集群中的消费者组偏移量。但当我们在辅助集群中启动消费者组时，它从一开始就开始消费消息，所以看起来消费者组偏移量没有在辅助集群中复制。有没有人可以提供一些建议，比如
浏览 0提问于2019-11-27得票数 0
我们有一个消费者服务，它总是试图使用消费者组从主题中读取数据。由于重新部署，我们的Kafka集群会定期关闭并重新创建。每当集群再次返回时，我们观察到尽管之前的主题被选取(可能来自zookeeper)，但之前的消费者组并没有被创建。正因为如此，我们使用以前的消费者组创建的正在运行的消费者进程被卡住了，永远不会出现。这是消费者群体的行为应该是什么样子，还是我们需要在某个地方启用某个配置？
任何帮助都是非常感谢的。
浏览 4提问于2018-08-06得票数 1
目前我们使用Apache NiFi通过Kafka consumer消费消息。kafka客户端的输出连接到hive处理器。有没
浏览 3提问于2019-08-04得票数 0
卡夫卡消费者使用图书馆卡夫卡(高层次消费者)连接到kafka集群，订阅10个主题和消费数据。存在分配分区事件。一旦连接到集群，消费者需要再次订阅主题吗？什么是检测使用者连接到代码集群的可靠方法？
浏览 2提问于2020-01-28得票数 0
回答已采纳
我有一种情况，我需要广播一条消息，然后等待及时的响应。换句话说，广播消息期望来自所有订阅消费者的超时周期内的响应。使用直接交换是很简单的。我可以使用RPCClient来等待响应。然后实现我自己的消费者和消费者，消费者从相同的交换和发送者发送到相同的回复队列。它会起作用吗？
请给我建议。谢谢!
浏览 1提问于2015-06-19得票数 2
情况如下，有一个系统，有一个服务器，一个生产者和1.n消费者。
实际上，我在运行时使用了分流来解决这个问题。
浏览 1提问于2012-10-04得票数 2
回答已采纳
2回答
我正在写一个生产者/消费者程序。我有3个消费者从队列中读取数据，一个生产者在队列中写入数据。当生产者在队列中编写内容时，它会使用phtread_cond_broadcast进行广播。然后消费者醒来了，但我在我的程序中找到了一个模式。其中一个消费者总是比其他消费者先醒来，然后清空队列。我的问题是，广播每次以相同的顺序唤醒所有线程是正常的吗？pthread_mutex_lock(&mutex1);
if(/* write something *&
浏览 9提问于2013-03-26得票数 1
我有一个场景，其中生产者生成有限的数量的消息，以及一组属于消费者组的消费者使用和处理消息。
卡夫卡是否有任何内在特征来实现这一目标？
浏览 0提问于2017-10-23得票数 2
1回答
服务器监听
、、、、
我和VB.NET一起工作Private Sub IPBroadcastTimer_Tick(ByVal sender As System.Object,下面是客户端和服务器端发生的情况：Client：“收听服务器广播</e
浏览 1提问于2012-08-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
