一、定時啟動的應用場景 比如現在單機環境下，我們需要利用Kafka做數據持久化的功能，由於用戶活躍的時間為早上10點至晚上12點，那在這個時間段做一個大數據量的持久化可能會影響數據庫性能導致用戶體驗降低，我們可以選擇在用戶活躍度低的時間段去做持久化的操作，也就是晚上12點后到 ...

應用服務啟動時，KafkaListener默認會自動啟動進行消費，如果想不自動消費，可以設置AutoStartup屬性值為false 完整消費代碼vk ...

消費者監聽類實現AcknowledgingMessageListener這個監聽器，可以實現手動提交offset： ...

講述的spring-kafka框架的kafkaListener注解的深入解讀和使用案例。 解讀 源碼解讀 ...

spring-kafka的官方文檔介紹，可以知道自1.1版本之后， @KafkaListener開始支持批量消費，只需要設置batchListener參數為true 把application.yml中的enable-auto-commit設置為false,設置為不自動提交 ...

前言 本文主要講述一下spring for kafka的consumer在spring.kafka.consumer.enable-auto-commit是false情況下，AckMode的選項，及手動提交分析總結。 AckMode Manual Commit ...

spring-kafka的官方文檔介紹，可以知道自1.1版本之后， @KafkaListener開始支持批量消費，只需要設置batchListener參數為true 把application.yml中的enable-auto-commit設置為false,設置為不自動提交 ...

spring-kafka1.3.3（對應kafka-clients版本0.11.0.0，請使用於kafk ...