kafka-producer-api

1熱度

1回答

所以我想實現發送通知kafka生產者到kafka消費者的簡單應用程序。到目前爲止，我已經成功發送String消息到生產者consumer.But當我嘗試發送通知對象kafka消費者沒有收到任何對象。這是我使用的代碼。 public class Notification implements Serializable{ private String name; private

3熱度

3回答

如果消息是由製片人製作的，如何獲得卡夫卡經紀人的確認？

我想在收到消息時得到經紀人的回覆。我曾嘗試使用CallBack機制（通過實現CallBack）在KafkaProducer.send中使用，但它沒有工作，並沒有調用onCompletion方法。當我關閉Kafka服務器並嘗試生成消息時，它確實調用了回調方法。是否有任何其他方式獲得承認？ @Override public void onCompletion(RecordMetadat

0熱度

3回答

Kafka Producer行爲

我在本地主機上設置了Kafka，並試圖監控Kafka Producer在網絡問題情況下的行爲。即使所有經紀人都關門，製片人也不會給出任何錯誤。我正在使用同步製作者和Kafka版本0.8。如果所有的經紀人都失敗了，生產者是否可以接收異常？

3熱度

1回答

Java消費者羣失蹤？

我最近設置了一個測試Kafka集羣。我正在運行一個消費者組織，傾聽項目，事情似乎有效。消費羣組的名稱是default。令我驚訝的是，上市的消費羣體給我一個空列表： $ ./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list $ 此外，明確查詢偏移不會產生任何東西： $ ./bin/kafka-consumer-grou

1熱度

1回答

EvaluationContext Null Spring集成和卡夫卡

我試圖在Spring集成中定義一個簡單的消息流，從一個通道讀取數據，然後將消息轉儲到卡夫卡隊列中。爲此，我正在使用spring-integration-kafka。問題是我得到一個EvaluationContext錯誤，我不能解碼。這裏是我的XML配置： <int:channel id="myStreamChannel"/> <int:gateway id="myGateway" servic

0熱度

1回答

我可以在三臺不同的機器上安裝生產者，經紀人和消費者嗎？

我對卡夫卡相當陌生。我有以下結構： 1) 2 servers runing application logics and database, can I write kafka producer on these servers wrapped with docker container ? 2) 1 server reserved for kafka broker and zookeeper

2熱度

1回答

Kafka 0.8.2.2 - 無法發佈消息

我們編寫了一個用於發佈消息給kafka的java客戶端。代碼如下 Properties props = new Properties(); props.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "202.xx.xx.xxx:9092"); props.setProperty(ProducerConfig.METADATA_FETC

0熱度

1回答

卡夫卡addtional分區密鑰或partitoner無鑰匙

我在卡夫卡新，並有一些問題。我知道我們可以使用自己的分區邏輯實現Partitioner類，它根據消息密鑰返回特定的分區。此外，我們可以設置日誌壓縮策略，在該策略下僅存儲具有相同密鑰的最新版本的消息。但我需要爲此操作提供不同的消息密鑰。例如，我們擁有ID和地址（city_id）的實體。我想根據city_id選擇分區，只存儲有關具有相同ID的人的最新信息。有什麼辦法可以解決這個問題嗎？對不起我的

3熱度

4回答

Kafka：如何連接kafka-console-consumer以獲取遠程代理主題內容？

我在ec2上的一臺機器上安裝了kafka zookeeper和3個broker，端口爲9092..9094，並試圖從另一臺機器上使用主題內容。端口2181（zk），9092,9093和9094（服務器）對消費者機器開放。我甚至可以做一個bin/kafka-topics.sh --describe --zookeeper 172.X.X.X:2181 --topic remotetopic這使我主

1熱度

1回答

卡夫卡經紀人是否爲每封郵件或每批消息發送ACK？

我正在使用Kafka 0.8.2。由於這份文件說： batch.num.messages指定：消息的數目使用異步模式時，在一個批次發送。生產者將等待，直到這個數量的消息準備發送或達到queue.buffer.max.ms。 and request.required.acks控制經紀人確認請求。我想知道卡夫卡經紀人如何發送此確認信息，它是否爲該批次或每條消息發送ACK？