spring-kafka

0熱度

1回答

Acknowledgement.acknowledge（）在spring-kafka中拋出異常@KafkaListener

當我將enable.auto.commit設置爲false並嘗試使用基於註釋的spring-kafka @KafkaListener手動提交偏移時，我得到一個org.springframework.kafka .listener.ListenerExecutionFailedException：監聽方法無法進入的消息被調用我有一個非常簡單的代碼如下： @KafkaListener(id = "s

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回答

雲中的卡夫卡消費者

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

0熱度

1回答

Spring Cloud Stream Producer在使用Spring Kafka Consumer時添加「垃圾」字符

我們的微服務正在使用JDK 8，Spring Cloud Stream API和Spring Boot 1.5.2.RELEASE在Kafka Queue上生成消息。對於消費者API，我們使用的是Spring Kafka 1.1.2.RELEASE，特別是@KafkaListener。消息類型的應用程序JSON 我們注意到，消費者有附加到附近的「的contentType」，該消息的一些垃圾字符被如