spring-kafka

1熱度

1回答

我決定回到我和春天啓動器，我已經在這裏提到的整合卡夫卡度量的想法： https://github.com/spring-projects/spring-boot/issues/6227 截至目前我有一個單獨的帶有工作代碼的「sandbox」項目，我想將它合併到Spring Boot中。現在我有點困惑。我的測試部分需要powermock嘲笑卡夫卡的「超安全」類： package org.apache

2熱度

1回答

單個Spring的KafkaConsumer偵聽器是否可以偵聽多個主題？

任何人都知道單個聽衆是否可以聽下面的多個主題？我知道只是「topic1」的作品，如果我想添加額外的主題怎麼辦？你可以在下面展示兩個例子嗎？謝謝您的幫助！ @KafkaListener(topics = "topic1,topic2") public void listen(ConsumerRecord<?, ?> record, Acknowledgment ack) { System

3熱度

1回答

爲什麼卡夫卡消費者需要很長時間才能開始消費？

我們開始一個Kafka消費者，傾聽一個可能尚未創建的主題（儘管主題自動創建已啓用）。此後不久，生產者正在發佈有關該主題的消息。但是，消費者需要花費一些時間通知這需要5分鐘。此時消費者撤銷其分區並重新加入消費者羣體。卡夫卡重新穩定了這個組織。查看消費者與卡夫卡日誌的時間戳，這個過程在消費者端實例化。我想這是預期的行爲，但我想了解這一點。這實際上是重新平衡（從0到1分區）嗎？如果我們預先創建主題

1熱度

1回答

spring kafka在運行時優雅地關閉生產者

我們有一個使用spring-kafka的spring引導應用程序。當我們更新配置屬性時，我們想禁用kafka生產者（kafkatemplate）。我已經試過使用條件bean，並使用applicationcontext刷新。有沒有辦法使用spring-kafka正常關閉kafkaproducer？

1熱度

1回答

Spring-Kafka反序列化

我正在嘗試製作一個正在偵聽特定主題並將消費的消息處理爲JSON的kafka消費者。我試着按照春季文檔here給出的方法，但我無法將消息作爲JSON獲取。這是我的接收機設置代碼： @Configuration @EnableKafka public class ReceiverConfig { @Value("${kafka.bootstrap.servers}") private St

6熱度

2回答

如何使用Spring雲流實現微服務事件驅動體系結構Kafka和數據庫每個服務

我試圖實現事件驅動體系結構來處理分佈式事務。每個服務都有自己的數據庫，並使用Kafka發送消息來通知其他微服務有關操作。一個例子： Order service -------> | Kafka |------->Payment Service | | Orders MariaDB DB Payment MariaDB Database 訂單接收訂單請求

1熱度

1回答

spring-kafka：如何將一個方法傳遞給另一個方法，哪個（通過設計）永不返回？

對Java完全陌生。寫彈簧卡夫卡的應用程序，它具有以下卡夫卡監聽方法： @KafkaListener(id = "receiver-api", topicPartitions = { @TopicPartition(topic = "topic1", partitionOffsets = @PartitionOffset(partition

1熱度

1回答

如果有服務異常，則KafkaMessageListenerContainer會重新處理一條消息

我們希望有一個Spring Kafka偵聽器，它的配置方式是，如果任何外部服務關閉，我們不想丟失從Kafka消耗的消息。我們希望恢復到成功處理。請問您可以使用我可以用來實現相同的配置。如果我批量使用消息，該如何處理它。我們使用卡夫卡0.9

2熱度

2回答

慢製片人從同一個JVM

運行卡夫卡消費者和生產者時，我使用卡夫卡0.8和彈簧集成 - 卡夫卡1.2.0.RELEASE 我有2個主題命名爲原發性和繼發性。我需要從主要主題進行消費，並且在某些處理需要產生次要主題以便稍後進行下一組處理。雖然從主要主題的消費正常工作，但生產到次要主題幾分鐘後開始失敗。問題開始於我設定的500毫秒後發送請求到kafka超時。結束線程池被耗盡。如果我試圖將事件發生到另一個kafka集羣的次要

0熱度

2回答

有沒有kafka 0.8.2.2的spring支持？

我想使用彈簧支持與kafka集成。服務器版本是0.8.2.2，但我可以找到的所有春季項目都使用較新的kafka。甚至spring-kafka-1.0.0使用kafka 0.9.0.1。我讀到卡夫卡客戶端不是向後兼容的。所以問題是：是否有任何春季支持老卡夫卡版本，或者我必須得到官方卡夫卡客戶端，並自己做？