1、配置信息 Git地址：https://github.com/wangymd/myKafka.git ...

kafka概念 　　Topic：消息根據Topic進行歸類，可以理解為一個隊里。　　Producer：消息生產者，就是向kafka broker發消息的客戶端。　　Consumer：消息消費者，向kafka broker取消息的客戶端。　　broker：每個kafka實例(server)，一台 ...

1、kafka簡介　　1.1：Kafka是由Apache軟件基金會開發的一個開源流處理平台，由Scala和Java編寫。Kafka是一種高吞吐量的分布式發布訂閱消息系統，它可以處理消費者在網站中的所有動作流數據。 這種動作（網頁瀏覽，搜索和其他用戶的行動）是在現代網絡上的許多社會功能 ...

kafka消費過程難免會遇到需要重新消費的場景，例如我們消費到kafka數據之后需要進行存庫操作，若某一時刻數據庫down了，導致kafka消費的數據無法入庫，為了彌補數據庫down期間的數據損失，有一種做法我們可以指定kafka消費者的offset到之前某一時間的數值，然后重新進行消費 ...

kafka消費過程難免會遇到需要重新消費的場景，例如我們消費到kafka數據之后需要進行存庫操作，若某一時刻數據庫down了，導致kafka消費的數據無法入庫，為了彌補數據庫down期間的數據損失，有一種做法我們可以指定kafka消費者的offset到之前某一時間的數值，然后重新進行消費 ...

1.配置pom包 <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> < ...

第一個文章 https://www.jdon.com/49366 在分布式系統中，重試是不可避免的，我們經常使用后台跑定時進行數據同步，同步不成功就實現重試，重試次數多少取決於你追求一致性還是可用性，如果希望兩個系統之前無論如何都必須一致，那么你設置重試次數為無限,當然這是理想情況 ...

https://blog.csdn.net/qq_40543961/article/details/82793511 ...