02.Java Stream Collectors各種方法使用實例 最近這段時間一直在學(xué)習(xí)java8的lambda和stream api的使用奶卓，...

前言 之前公司有一個需求要實現(xiàn)把rocketmq和rabbitmq中的數(shù)據(jù)對接到kafka中，雖然flume中已經(jīng)提供了很多種類的sou...

06. KafkaConsumer是如何處理過期offset(越界offset)請求 該篇文章是基于以下的條件編寫完成的 1. Kafka cl...

01進(jìn)度條 前提： 在平時做開發(fā)是遇到一個這樣的問題著榴，有一個初始化操作比較耗時，如果做成同步實現(xiàn)憎乙，前端的http請求會超時票罐，因此做成了異...

05.kafka connect Distributed 模式環(huán)境安裝配置 前言： 前段時間在調(diào)研通過PostgreSQL Logica...

04. kafka log數(shù)據(jù)清理 前言：前端時間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼，主要是從整體流程上分析的源碼泞边。今天有...