kafka-producer-api

0熱度

2回答

對於閱讀的所有分區中的話題：〜斌/ kafka-console-consumer.sh --zookeeper本地主機：2181 --topic myTopic --from-開始我怎麼能消耗特定的分區的話題？（例如使用分區鍵13）以及如何在帶有特定分區鍵的分區中生成消息？可能嗎？

1熱度

3回答

卡夫卡：如何在卡夫卡實現循環分區

我是卡夫卡的新人。我的要求是，我有兩個分區，例如Partition-0和Partition-1，我有值列表也包含KEY值。我想根據我的密鑰存儲數據，如鍵1將進入分區0，鍵2將進入分區1。使用舊的API有辦法實現，就像我們需要實現分區界面一樣，但我怎樣才能用新的API來實現。謝謝

1熱度

1回答

Apache Kafka：生產者不生產所有數據

我是新的卡夫卡。我的要求是，我有兩個數據庫源和目標表。現在我想從源表中獲取數據並將其存儲到這些kafka之間的目標中，並將作爲生產者和消費者使用。我已經完成了代碼，但問題在於，當生產者生成數據時，有些數據會錯過生成。例如，如果我在源表中有100條記錄，那麼它不會生成全部100條記錄。我使用的卡夫卡0.10 MyProducer Config- bootstrap.servers=192.168.1

0熱度

1回答

是否可以使用相同的分區創建2Topics？

我的要求是創建2個主題與相同的分區，如果我產生消息到兩個不同的主題數據可以存儲在只有一個分區。是否可以使用相同分區創建2個主題？要acheive 多租戶，例如，多個租戶（租戶-1，租戶-2），爲每個租戶，我們有其特定的主題。 Tenant-1 ---> has Topic1, Topic2, Topic3 Tenant-2 ---> has Topic4, Topic5. 希望在單個分區

-1熱度

1回答

什麼是卡夫卡？它是一個數據存儲服務器嗎？

kafka是數據存儲服務器嗎？按照我的理解，例如，用戶在遊戲客戶端購買了物品。遊戲服務器存儲購買日誌。而遊戲服務器通過kafka製作者將數據發送到kafka服務器。卡夫卡存儲這些數據，並通過消費者發送到需要購買日誌的服務器。它沒事嗎？我無法理解卡夫卡的概念。

4熱度

1回答

無法在docker中運行的服務產生消息給kafka

我在端口5000上的docker容器中運行了一項休息服務，該服務用於通過kafka主題生成運行Docker容器的消息。我已經配置我的生產者客戶端與以下特性： - bootstrap.servers=localhost:9093 我也開始了我的包含下面的命令： - docker run -d -p 127.0.0.1:5000:5000 <contained id> ，我也做了以下配置做廣

1熱度

3回答

NoBrokersAvailable：NoBrokersAvailable-Kafka錯誤

我已經開始學習Kafka了。嘗試對其進行基本操作。我對「經紀人」這個問題感到厭煩。我的卡夫卡正在運行，但當我想創建一個分區。 from kafka import TopicPartition (ERROR THERE) consumer = KafkaConsumer(bootstrap_servers='localhost:1234') consumer.assign([TopicPart

0熱度

1回答

使用kafka生產者作爲日誌appender

我已經通過以下基本kafka生產者文檔實施了一個有kafka生產者的日誌appender。我的配置如下所示，我使用KafkaProducer並使用send（）將每個日誌發送到kafka。在我的情況下，我不能使用KafkaAppender，因爲我們不支持slf4j或log4j。如何對這些日誌進行批處理，以及如何優化以下配置以處理大量日誌。 Properties props = new Proper

0熱度

1回答

是否可以使用kafka獲取GoogleAnalytics數據並通過火花流處理？

你可以請任何人試圖將谷歌分析與卡夫卡..並處理這些數據火花流。謝謝！

0熱度

1回答

Kafka Rest的示例

在Java中是否有使用Kafka rest api的生產者和消費者羣體的良好示例。我不尋找生產者和消費者的簡單消費者或卡夫卡客戶端的例子。任何幫助被認可。