spring-kafka

0熱度

2回答

我有一個Spring Cloud微服務，它在卡夫卡經紀人上發佈消息，這個微服務可以通過REST api訪問。我想將提交狀態返回給調用者，但看起來像Java不等待。如何讓我的代碼在返回之前等待成功或失敗？繼承人的代碼： kafkaProduc.send("topictest", msg).addCallback( new ListenableFutureCallback<SendR

1熱度

3回答

春天開機卡夫卡LocalDateTime

我有一個包含java.time.LocalDateTime一個基本的POJO： package foo.bar.asire.api.model; import java.time.LocalDateTime; public class Address { private Long id; private Integer houseNumber; privat

0熱度

1回答

Filter-Interceptor-Kafka話題

您好，我正在嘗試構建一個分析引擎來確定客戶端正在使用的urls \ events的實時分析以及記錄api的性能。以下是我的規劃，實現邏輯： 1.創建一個過濾器攔截的URL 2.代碼過濾器具有使用MVC攔截器攔截他們邏輯可重複使用的罐子。 3.如果URL模式匹配，攔截器將生成事件並將其發佈到kafka流中。我的困惑是這是實現這一目標的最佳方法。或者是否有其他更好的方法，記住高收入流入apis。

0熱度

1回答

@KafkaListener方法不帶彈簧工作@profile註釋

我有2種@KafkaListener方法監聽同一tipic TopicA，但他們也標註了不同的@profile（「開發」）和@profile（「prod」），我設置了spring.profiles.active = dev，併發送消息給TopicA，兩個方法都可以使用這個消息。是一個已知的bug的@KafkaListener與@profile？或者我的配置有問題？

0熱度

2回答

kafka如何實現與主題/分區/偏移一模一樣的消息傳遞邏輯

我設法獲得用@KafkaListener註釋的方法中的主題/分區/偏移量，但是如何使用這些數據來實現一次性消費者邏輯？我正在使用ConcurrentKafkaListenerContainerFactory並設置concurrenc = 4，並將AckMode設置爲MANUAL。我目前的方式是使用redis進行重複數據刪除：我使用topic：partition作爲redis關鍵字，偏移量作爲

1熱度

2回答

發送消息給Kerberized Kafka。從kafka模板（spring-kafka）版本1.15（不使用Spring引導）

Using this kafka集成項目版本1.15由於兼容問題。如何使用發送消息到Kerberized kafka，我們沒有使用spring boot .how來設置屬性發送消息給kafka？我試圖尋找documentation，但是在ProducerConfig中找不到與kerberos相關的屬性。

0熱度

1回答

春 - 卡夫卡快照構建存在的地方？

我需要目前只存在於主服務器中的代碼，而且文檔特別提到了一個名爲2.0.0.BUILD-SNAPSHOT的版本，但如果我能確定哪個存儲庫託管的話，我將會被定罪這樣的構建。任何人有任何線索？此外，是否有關於發佈時間表的任何信息發佈？我不願意針對1.x API進行開發，因爲我想要重試和恢復功能（它不適用於2.0.0里程碑版本中的任何一個，因此我需要快照），但我不想承諾一個未發佈的圖書館，而沒有一定的時

0熱度

1回答

春季卡夫卡模板執行示例尋求偏移，確認

我是spring-kafka-template的新手。我嘗試了一些基本的東西，他們工作得很好。但是，我想實現在Spring Docs提到的一些概念，如： Offset Seeking 承認聽衆我嘗試過網上找到它的一些例子，但沒有成功。只有我找到的東西是它的源代碼。我們遇到了與本帖子中提到的相同的問題Spring kafka consumer, seek offset at runtime。但

1熱度

1回答

Spring Cloud Stream Kafka支持嵌入式標頭嗎？

根據這一話題： Kafka Spring Integration: Headers not coming for kafka consumer - 這是沒有頭的卡夫卡但documentation支持說： spring.cloud.stream.kafka.binder.headers 名單自定義標題將由活頁夾傳輸。默認值：空。我不能得到它與彈簧雲流 - 粘合劑 - 卡夫卡工作：1.2.0.R

0熱度

2回答

彈簧雲流默認自定義消息頭

是否有配置默認Message<T>頭時從該方法返回的值所生成的消息中的方式： @Publisher(channel = "theChannelname") public MyObject someMethod(Object param) { ... return myObject; } 或 @SendTo("theChannelname") public MyObje