我已经开发了一个基于Java卡夫卡消费者在那里我有100个线程为每个消费者实例和消费过程开始时，每个线程都有一个分区（因为有100个分区）和消费已经完成了。 我打算转和的NodeJS使用卡夫卡节点作为客户端库，我如下所述消耗话题： var kafka = require('kafka-node');
var HighLevelConsumer = kafka.HighLevelConsumer;
我有四个消费者，当发生错误时，消息发布到默认EasyNetQ_Default_Error_Queue是否有可能向每个队列消费者写入自己的错误交换 例如; Queue Name : A ErrorExchange :A_ErrorExchange
Queue Name : B ErrorExchange :B_ErrorExchange
bus.Advanced.Conventions.Err
我正在设置一个标准的独立线程，在C＃中监听RabbitMQ。假设在线程监听的方法是这样的： public void Listen()
{
using (var channel = connection.CreateModel())
{
var consumer = SetupQueues(channel);
while (true)
{