spring-kafka

2熱度

1回答

我在我的Spring Boot應用程序中使用了KafkaListener接口，工作得很好。偏移由Kafka本身存儲。現在讓我們說一個話題的消費者部署一個新的版本，並擰緊2個小時的消息。然後，他們修復了該應用程序，並希望以兩小時前的偏移量啓動新版本。我可以在之前的consumer.offsetsForTimes（）調用中使用consumer.seek（），但這僅僅在我使用輪詢機制時很直接，而不是

0熱度

1回答

健康卡夫卡粘結劑始終是未知

當我嘗試激活在Spring Cloud Stream Reference Documentation 健康端點的回報作爲解釋卡夫卡粘結劑的健康指標： binders":{"status":"UNKNOWN","kafka":{"status":"UNKNOWN"}}} 我的配置包含如記錄： management.health.binders.enabled=true 我已經調試過Binde

0熱度

2回答

如何理解消費者和聽衆在春天kafka

我使用彈簧kafka與多線程功能（ConcurrentKafkaListenerContainerFactory），我發現了兩種類型的線程名稱是這樣的： 1.＃0-1-kafka-consumer-1 2 。＃0-1-kafka-listener-3 那麼我該如何理解這2種線程呢？他們之間有什麼關係？在此先感謝！

0熱度

1回答

重置卡夫卡消費者的上一次偏移量

我想重置與給定使用者相對應的先前偏移量。原因：我寫我的應用程序的spring-boot消費者代碼是使用「最早的」作爲自動偏移重置的值。由於現在偏移量已存儲在__consumer_offsets中，因此將自動偏移重置的值更改爲最新值不起作用。注意：我使用的kafka版本高於0.9。不知道刪除使用者是否會有所幫助，因爲我知道偏移量現在存儲在主題__consumer_offsets中。

1熱度

1回答

卡夫卡同步生產者需要更長的時間在第一個請求

我使用春季雲流卡夫卡同步生產者在春季啓動微服務。每次我們部署服務時，第一次打電話給卡夫卡需要超過20秒才能將消息發佈到主題。但隨後的所有調用幾乎需要3至4毫秒。這個問題也是隨機發生的，並且是間歇性的，但主要發生在我們重新啓動服務時。我們使用卡夫卡版本0.9.0.1和gradle這個依賴關係如下依賴{ compile('org.springframework.cloud:spring-cloud

0熱度

1回答

春季Kafka客戶端無法從啓用了Kerberos的Kafka Broker主題獲取消息

我們最近有Kaker集羣kerberized，我們開始在代理中讀取主題中的消息時遇到問題。我們使用spring kafka 1.1.2.RELEASE和kafka客戶端0.10.0.1。在完成Apache Kafka文檔的建議後，我對項目進行了以下更改。在消費者屬性中添加了security.protocol SASL_PLAINTEXT。添加了相應的JAAS文件並提供了VM參數中的路徑。

0熱度

2回答

ListenableFuture - 如何在返回之前等待

我有一個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熱度

2回答

Spring Kafka 1.2.0.Relase.Jar，Spring-boot-starter 1.5.3和spring-messaging 4.2.0

我試圖運行spring-kafka集成。當我嘗試啓動Spring時收到以下錯誤消息開機。 https://github.com/spring-projects/spring-kafka/issues/172 按照上述鏈接，4.3與Kafka 1.1以上版本兼容。有人試過這種組合。記住，如果你使用的彈簧消息（版本4.3）的代碼不會編譯和Eclipse抱怨 Maven的配置是 <dependency

1熱度

1回答

春季引導：排除一些自動配置的豆

我有一個使用spring-kafka的Spring引導項目。在這個項目中，我已經構建了一些包裝spring-kafka bean的事件驅動組件（即KafkaTemplate和ConcurrentKafkaListenerContainer）。我想讓這個項目成爲一個可重用的庫，可以跨越一系列Spring引導應用程序。但是，當我從春天啓動應用程序添加依賴於這個庫我在應用程序啓動時出現錯誤： APPLI