consumer

0熱度

2回答

我正在通過不同的方法解決生產者/消費者問題。我目前正在從事的工作涉及到我自己實現的一個信號量，與Peterson的解決方案配合使用，以保護信號量的down（）和up（）函數調用。問題是，我在C中工作，我可以考慮創建信號量的唯一方法是使用帶有函數指針的結構體，用於down（）和up（）。這是正確的想法嗎？

2熱度

1回答

卡夫卡沒有在主題中均勻地填充分區

我想擁有10個分區的1個主題。我正在使用Kafka的默認配置。我用這個助手腳本創建了10個分區的主題，現在我正在爲它生成消息。的事情是，它好像有隻有5從中獲取消費者數據分區。讓我們更詳細地描述它。我知道常用的東西，你需要每個分區的一個消費者線程。我希望能夠提交每個分區的偏移量，並且只有當每個分區的每個使用者連接器有一個線程時（我正在使用高級使用者）纔有可能。所以我創建10個線程，每個線程我

0熱度

1回答

無法實現使用EasynetQ客戶對於.NET

我使用RabbitMQ的隊列解決方案，我有4個隊列，一個消費者在RabbitMQ的一個消費者多處理器。我希望我的消費者使用所有這些隊列，併爲每個隊列提供單獨的處理程序。我GOOGLE了這一點，並發現的RabbitMQ和EasyNetQ（.NET客戶端的RabbitMQ），提供了先進的API（this link和This link）在此文章中提供的示例代碼定義爲多處理器這一功能消費者： bus.

0熱度

1回答

如何在Easynetq中爲每個使用者聲明自定義錯誤excahange？

我有四個消費者，當發生錯誤時，消息發佈到默認EasyNetQ_Default_Error_Queue是否有可能向每個隊列消費者寫入自己的錯誤交換例如; Queue Name : A ErrorExchange :A_ErrorExchange Queue Name : B ErrorExchange :B_ErrorExchange bus.Advanced.Conventions.Err

2熱度

2回答

在C＃客戶端爲RabbitMQ正常停止消息消息的優雅方式是什麼？

我正在設置一個標準的獨立線程，在C＃中監聽RabbitMQ。假設在線程監聽的方法是這樣的： public void Listen() { using (var channel = connection.CreateModel()) { var consumer = SetupQueues(channel); while (true) {

2熱度

1回答

一位JMS消費者停止監聽活躍的mq主題，而第二位則不要

春季石英工藝每隔15分鐘在我的項目中運行，即每天工作96次。這從數據庫獲取某些記錄並將其發佈到REST服務（在JBoss 7上運行）。這些記錄通常在50到100個計數中。關於REST服務，有jms事件發佈者將該消息發佈在主題上。這個主題有兩個消費者。這一進程消息，並在移動交談第三方發送推送通知的消息（一般需要4至5秒以完成呼叫）由於它是主題對消費者接收的所有消息但是它們會根據某些屬性將它們

0熱度

1回答

JMS隊列消費者：同步接收（）或單線程onMessage（）

我需要從Q中消耗，並在每條消息上標記序列鍵以指示排序。即消費需要連續。從性能/吞吐量的角度來看，使用阻塞receive（）方法還是onMessage（）方法使用單線程配置的異步監聽器會更好？謝謝。

5熱度

2回答

如何驗證Amazon Kinesis Python客戶端正在工作

我正在嘗試使用Python的KCL庫（https://github.com/awslabs/amazon-kinesis-client-python）構建Amazon Kinesis Python使用者。我從檢查示例代碼開始。我能夠運行示例代碼的生產者和用戶腳本部分，但我無法驗證是否將來自我的kinesis流（帶有一個分片）的數據推送到示例Python使用者腳本sample_kclpy_app.p

1熱度

1回答

kafka消費者指定的輸出

我在kafka文檔中讀到： Kafka也有一個命令行使用者將消息轉儲到標準輸出。斌/ kafka-console-consumer.sh --zookeeper本地主機：2181 --topic測試--from-開始我不知道，如果我想消費者信息和他們推到另一個輸出，要添加到上述命令的選項。 kafka-console-consumer沒有--help選項，我找不到任何參數，命令選項。謝謝

1熱度

1回答

我在哪裏可以從一個主題使用kafka java api獲取所有消息

在命令行中，我可以使用「--from-beginning」獲取所有消息，但如何在同一個主題中獲得同樣的效果我編寫了一個Java程序，並使用高級消費者api。