consumer

2热度

2回答

我们正在制作一个卡夫卡队列，消息从源系统发布到该卡夫卡队列中。现在多个消费者可以连接到这个队列来阅读消息。虽然这样的消费者在此基础上的消息被分配到指定的groupId，如果两个应用程序具有相同的groupId他们都不会得到的消息。有没有一种方法，我可以强制每一个应用程序。有一个独特的消费者组织ID？

0热度

1回答

多的消费者在同一消费群

我有1对生产者和消费者1在同一组（我的组）。 # To send messages asynchronously producer = SimpleProducer(kafka, async=True) producer.send_messages("my-topic", "async message") # To consume messages, consumer1 consumer

0热度

1回答

JMS消耗多个主题

我是Java新手，正在研究消耗多个（不同）主题并将其发送到另一个服务器的项目。我想知道处理多个主题的最佳方式是什么。据我了解每个消费者被绑定到一个话题，所以，如果我不得不消耗多个主题，我需要一个消费者对每一个不同的主题。由于消费者进行阻塞调用，我需要调用每个消费者的线程来并行使用这些主题。如果我想提高吞吐量进一步它是一个很好的做法，每个消费者（附加到主题）一个老板线程，并让每个老板线程设置辅助

0热度

1回答

rabbitmq消费者获取不同路由密钥的消息

我们有两个消费者用c1（在php中）绑定交换1，队列1和路由密钥1;和c2（在java中）交换1，队列1和路由密钥2.即仅路由密钥不同，但交换和队列相同。在PHP ，我们结合为下列情况 $channel->queue_bind($this->queue, $this->exchange, $this->routing1); 在Java中，以下 channel.queueBind(queue,

2热度

1回答

Kafka和NodeJS的实时通知

在我的项目中，我必须设计一个实时通知系统。我做了下图。你可以看到，我用卡夫卡作为队列邮件系统，并且对的NodeJS建立的WebSocket服务器和卡夫卡的消费者。生产者将收集通知数据并将其推送给Kafka。如果数据属于该用户，消费者将阅读并处理来自Kafka的数据并通过websocket将其推送给客户端。通过上面的架构师，每个在线用户将打开一个Websocket连接并创建一个新的Consum

1热度

1回答

全部队列中的java blockingqueue消费块

我正在写一个小程序，将推特从Twitter公共流中放入HBase数据库。该程序使用两个线程，一个收集推文，一个处理它们。第一个线程使用twitter4j StatusListener获取推文并将它们放入一个容量为100的ArrayBlockingQueue中。第二个线程从队列中获取状态，过滤所需数据并将其移至数据库。处理比收集状态需要更多的时间。制片人看起来是这样的： public voi

1热度

1回答

JMS选择器与单个队列

我有一个应用程序，它使用AMQ代理上队列中的消息。我可能需要此应用程序的多个实例（出于性能方面的原因），在这种情况下，每个实例应使用来自队列的消息的子集。这个子集应该根据传入消息中'HeaderA'头的值来选择。 I.e. 实例1消费消息，其中HeaderA == X 实例2消耗的消息，其中HeaderA ==Ÿ 等（注：我知道，这样的设计是不是伟大，如果所有的实例等价并且可以消费任何消息，但由

0热度

1回答

没有解串器为阵列类型定义

我正在尝试使用webservice并面临问题。我导入了WSDL文件并生成了Java类。我可以连接到web服务，但是当我要求数据时，我得到这样的错误。 WSDL文件：https://www.geckobooking.dk/api7/webservice.php?WSDL 客户端代码 GeckobookingServiceLocator service = new GeckobookingServic

0热度

1回答

ActiveMQ的连接，不明数据类型：49

我使用ActiveMQ的从应用程序到另一个发送文件，我已经遇到这个错误当消费者试图在ActiveMQ的服务器连接。这里是连接方法 public void connect() { connectionFactory = new ActiveMQConnectionFactory( "tcp://" + Configuration.getInstance().ge

-1热度

3回答

是否有可能使用java编写kafka消费者接收的输出到文件

我有一个用java编写的卡夫卡生产者代码，用于编写卡夫卡消息。以及接收这些消息的消费者代码。是否有可能将消费者收到的消息写入java中的任何文本文件。