spring-kafka

0熱度

1回答

spring-cloud-stream-kafka在應用程序啓動後僅使用最新消息

在我們的項目中，我們使用spring-cloud-stream-binder-kafka 1.1.2版與kafka集成。最近我們遇到了這樣一種情況：我們的某項服務在啓動後會消耗某個主題的舊消息（已經消耗）。該主題有2個分區和2個消費者組成的消費者羣體。我們不確定偏移量是否適用於動物園管理員。在啓動過程中，每條消息都會引發錯誤消息。 [-kafka-listener-2] ERROR o.s.k.l

0熱度

2回答

KafkaProducerException上發送消息到一個主題卡夫卡生產

春天引導屬性：我得到的例外下面，當我試圖將消息發送到卡夫卡的話題 spring.kafka.bootstrap-servers=localhost:9092 spring.kafka.client-id=bam #spring.kafka.producer.acks= # Number of acknowledgments the producer requires the leader to

0熱度

1回答

春天卡夫卡不支持大消息的消費者

我使用的彈簧卡夫卡爲消耗LinkedIn large message supported Kafka client 生產的消息給出，如它的構造，這卡夫卡客戶始終覆蓋AUTO_OFFSET_RESET_CONFIG無法比擬的。 private LiKafkaConsumerImpl(LiKafkaConsumerConfig configs, Deserializer<K> keyDese

2熱度

1回答

啓用@KafkaListener從application.yml文件中獲取可變主題名稱

我試圖將多個主題加載到單個@KafkaListener，但由於我相信它正在尋找一個常量值，但初始化topics變量從application.yml文件導致的問題，我想知道如果有人可以幫我解決這個問題，或者提供我如何將多個Kafka主題加載到單個KafkaListener中的方向。我能夠通過將其在一個逗號分隔的對象聽在同一@KafkaListener多個主題，如下圖所示： @KafkaListen

0熱度

2回答

單個Spring的KafkaConsumer偵聽器可以偵聽來自同一個/一個分區的多條消息嗎？

提供了一個有n個分區的主題。 Spring的KafkaConsumer偵聽器可以通過哪種方式一次偵聽來自同一個/一個分區的多個消息？我試過ConcurrentKafkaListenerContainerFactory通過設置setBatchListener(true);但消費者已經開始消費來自不同分區而不是一個分區的多個消息。 public class BatchReceiverConfig {

1熱度

1回答

Spring Kafka - 運行時訂閱新主題

我使用註釋@KafkaListener來消費我的應用程序中的主題。我的問題是，如果我在卡夫卡創建了一個新話題，但我的消費者已經在運行，似乎消費者不會選擇新話題，即使它與我正在使用的topicPattern相匹配。是否有辦法定期「刷新」訂閱的主題，以便在運行的消費者中挑選並重新平衡新主題？我使用Spring Kafka 1.2.2和Kafka 0.10.2.0。 Regards

0熱度

1回答

使用多個主題名稱與KafkaListener註釋

也存在類似的問題，下面問： Can a single Spring's KafkaConsumer listener listens to multiple topic? 所以，我現在明白了，我可以提供一個字符串數組到KafkaListener註釋的主題參數，但我想知道以下內容：如何從屬性文件中獲取主題名稱作爲字符串數組？這個來自多個主題的閱讀如何影響偏移量？客戶（春季卡夫卡）會保持每個主題的

0熱度

1回答

春季卡夫卡消費者客戶端配置

我在哪裏我有兩個卡夫卡監聽器組件，每個組件聽一個不同的主題，並期待不同的有效載荷。我的問題是，我可以同時使用相同的客戶端ID還是它必須有所不同？如果client-id必須有所不同，我想了解可以有效使用client-id的用例。

0熱度

1回答

雲中的卡夫卡消費者

我使用的春季卡夫卡消費者包裹在春季啓動應用程序中，並在關鍵雲代工廠部署爲微服務。我正在部署15個應用程序的實例，其中包括15個kafka分區。由於這些實例中的大多數會逐個啓動，會有多次重新平衡嗎？在雲中部署kafka用戶的推薦方式是什麼？

0熱度

2回答

爲Spring Boot Kafka項目配置Kafka客戶確認模式

我正在使用Spring Boot 1.5.2.RELEASE和Spring Kafka 1.1.2.RELEASE版本。通過application.properties文件，我確實看到了可用選項（spring.kafka.consumer。*）來配置Kafka Consumer。我無法找到雖然是一種配置確認模式的方法。