spring-kafka

0熱度

1回答

不知道如果我做錯了一些事情，但我無法設法使其工作。以下是我的代碼： public class EventsApp { private static final Logger log = LoggerFactory.getLogger(EventsApp.class); @Value("${kafka.topic:test}") private String top

1熱度

1回答

春季Kafka，使用嵌入式Kafka測試

我們正在使用我們的Servicetest和嵌入式Kafka觀察一個奇怪的行爲。測試是斯波克測試中，我們使用JUnit的規則KafkaEmbedded和傳播brokersAsString如下： @ClassRule @Shared KafkaEmbedded embeddedKafka = new KafkaEmbedded(1) @Autowired KafkaListenerEndp

-1熱度

2回答

執行功能後，功能不工作迅速3

這是我想獲得執行後，下載所有細節和另一個功能，其中下載後更新UIElements的功能。此功能是內部「CurrentWeather.swift」 func downloadWeatherDetails(completed: (() ->())){ // tell Alimofire where to download let currentWeatherURL = URL(s

-6熱度

2回答

幫助及時通知我

我正在試着製作一個簡單的表格，例如http://birdboxx.com/，用戶可以輸入他們的電子郵件地址，以便在我們的網站啓動時收到通知。我已經看過他們使用的HTML，它看起來很簡單，我只是不確定如何編寫PHP部分。有人可能幫助我嗎？在此先感謝。

0熱度

1回答

SpringBoot/spring-kafka應用程序中的自動佈線KafkaTemplate會拋出空指針

我試圖在Spring Boot應用程序中使用spring-kafka KafkaTemplate將消息寫入Kafka主題。我創建了一個KafkaConfig類： @Configuration @EnableKafka public class KafkaConfig { @Value("${kafka.broker.address}") private String b

0熱度

2回答

只有第一次獲得一個記錄卡夫卡消費者獲得記錄？

我使用的是spring-kafka和spring-kafka測試版本1.0.2.RELEASE。在我的測試之一，我的應用程序發送100條記錄在一排單TopicPartion上使用KafkaTemplate，大多默認的配置設置的EmbeddedKafka實例。我使用KafkaTestUtils.getRecords（消費者）的方法來嘗試獲得從卡夫卡實例的記錄，並驗證它們已經全部發送。我第一次打

0熱度

1回答

如何確保消息不會丟失使用彈簧KafkaMessageListenerContainer.java

一旦我收到來自kafka的消息，我需要運行一個長時間運行的進程（最多需要20秒），我只需要將消息視爲成功此過程完成。另外我需要確保每個消息至少處理一次。使用KafkaMessageListenerContainer具有以下屬性的思維： ThreadPoolTaskExecutor類爲listenerTaskExecutor 使用類型AcknowledgingMessageListener

1熱度

1回答

如何在Spring XD中從Kafka接收模塊獲取確認時手動提交Kafka源模塊上的偏移量？

在XD流中，消息通過源模塊從Kafka主題中消耗，然後發送到接收器Kafka模塊。開發自定義源和接收卡夫卡模塊的原因是，我只想從源模塊更新偏移量，只有當我從下游接收器模塊獲得成功發送消息的確認時。我正在使用Spring集成Kafka 2.0.1.RELEASE和Spring Kafka 1.0.3.RELEASE，並在Kafka 0.10.0.0環境中使用了主題。我曾嘗試以下：源模塊配置： @

1熱度

1回答

Spring Kafka傾聽所有主題並調整分區偏移

基於spring-kafka的文檔，我使用基於Annotation的@KafkaListener來配置我的客戶。我看到的是 - 除非我指定的偏移量爲零，同比開始，卡夫卡消費者拿起未來的消息，而不是現有的。（我明白這是一個預期的結果，因爲我沒有指定偏移量，我想要的）我在文檔中看到一個選項來指定一個主題+分區組合，以及零偏移，但如果我這樣做 - 我必須明確指定我希望消費者傾聽哪個主題。使用方法

0熱度

1回答

如何在Xamarin表單中播放視頻播放器中的視頻？

我正在使用xamarin格式。我試圖在視頻播放器中播放視頻。出於同樣的我用從GitHub此示例代碼 https://github.com/xamarin/customer-success-samples/tree/master/samples/Xamarin.Forms/FormsNativeVideoPlayer ，但問題是，當我把「http://clips.vorwaerts-gmbh.de/