producer

0熱度

2回答

我有一些問題，卡夫卡製片人，但我不知道我可以解決它我Maven的相關性： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.10.1.1</version> </dependency> 如果我創建： Producer<S

0熱度

1回答

如何保護進程間生產者消費者消息傳遞機制免受因一方崩潰而導致的損壞？

我在Windows上爲一個生產者和一個消費者在共享內存中實現了一個進程間消息隊列。我使用一個命名信號量來算空槽，一個信號燈入選計數滿插槽和一個命名的mutex來保護共享內存中的數據結構。考慮，例如消費者方面。生產者方面是相似的。首先它等待對充分旗語然後（1）它需要由互斥下的隊列中的消息，然後它用信號空信號（2）問題：如果消費者進程在（1）和（2）之間崩潰，那麼有效的進程可以使用的隊列中的

0熱度

1回答

RabbitMQ與Arduino Uno

我第一次使用RabbitMQ和Arduino，我需要發佈數據。所以我使用了PubSubCLient類。這是代碼： #include <SPI.h> #include <PubSubClient.h> #include <Dhcp.h> #include <Ethernet.h> #include <EthernetUdp.h> #include <Dns.h> #include <Et

0熱度

1回答

如何使用kafka-avro-console-producer？

如果我使用'kafka-console-producer' - 它會自動拾取JASS文件並正常運行（可以產生遠程主題）。如果我使用「卡夫卡的Avro控制檯生產者」與完全相同的配置但增加了架構屬性 - 它抱怨JASS配置： 'Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.s

1熱度

2回答

做更新版本的卡夫卡生產者仍然有「producer.type」？

舊版本的文檔說這是基本屬性之一。新版本的文檔根本沒有提及它。做更新版本的卡夫卡生產者仍然有「producer.type」？或者，新的生產者總是異步的，我應該調用future.get（）來使其同步？

0熱度

2回答

使用分區獲取kafka 0.8.0中生產者的分區數量對於方法

我們是否支持kafka 0.8.0版本中的生產者的partitionsFor方法？我想用這種方法來獲得給定kafka主題的分區數量。如果此方法在kafka 0.8.0中不可用，那麼在此特定版本的kafka中獲取生產者中分區數的最簡單方法是什麼？

9熱度

2回答

春季卡夫卡異步發送呼叫塊

我正在使用Spring-Kafka 1.2.1版本，並且當卡夫卡服務器關閉/不可達時，異步發送呼叫塊一段時間。它似乎是TCP超時。該代碼是這樣的： ListenableFuture<SendResult<K, V>> future = kafkaTemplate.send(topic, key, message); future.addCallback(new ListenableFutureC

0熱度

1回答

如何在防火牆/代理服務器上配置kafka生產者？

我們在AWS上安裝單節點kafka。我們能夠在這種環境中運行卡夫卡生產者和消費者。但是，儘管我們的客戶試圖向我們的kafka代理髮送消息（AWS環境之外），但他們的消息仍然滯留在他們的防火牆中。所以客戶卡夫卡生產者是位於防火牆/代理服務器，如何使我們的客戶在他們的最終繞過代理後通過卡夫卡發送郵件設置。

0熱度

1回答

ActiveMQ，多個會話與多個連接

我想在我當前的項目中使用ActiveMQ，但是我對於何時利用多個連接感到困惑。由於我們可以在單個連接中創建多個生產者，那麼需要多個連接。我試着在網上卻無法找到任何有用的資源，可以幫助我理解它的深度找到它。這將是非常有益的，如果有人可以共享和ActiveMQ工作的他的實踐經驗，並幫助我們的理解，當創建每個生產者和當在同一個連接創建多個生產商的多個連接。

1熱度

1回答

管道消費者/生產者：誰應該是消費者/生產者的父/子後叉

首先，對不起，如果使用不好的英語。在我的筆記中，我寫過這個子進程通常是製作者，但我不明白爲什麼。在fork（）調用之後，消費者和生產者是誰？問題是：如果子進程是生產者，他會在父進程完成之前完成，這意味着子進程成爲殭屍進程。關於這個問題，我試圖瞭解小素描：