04. kafka log數(shù)據(jù)清理 前言:前端時(shí)間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼炕柔,主要是從整體流程上分析的源碼象缀。今天有一個(gè)同事正好有一個(gè)同事問到ka...
![240](https://cdn2.jianshu.io/assets/default_avatar/10-e691107df16746d4a9f3fe9496fd1848.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
IP屬地:北京
04. kafka log數(shù)據(jù)清理 前言:前端時(shí)間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼炕柔,主要是從整體流程上分析的源碼象缀。今天有一個(gè)同事正好有一個(gè)同事問到ka...
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析 我們?cè)谑褂肒afkaProducer向kafka broker發(fā)送消息時(shí)候,我們都會(huì)有一個(gè)疑問prod...
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析 我們?cè)谑褂肒afkaProducer向kafka broker發(fā)送消息時(shí)候斋扰,我們都會(huì)有一個(gè)疑問prod...
02. KafkaConsumer訂閱topic數(shù)據(jù),是如何實(shí)現(xiàn)加入組以及再平衡原理 上一篇在分析Consumer不通訂閱方式的時(shí)候褥实,提到了同一消費(fèi)組下有多個(gè)消費(fèi)者時(shí)呀狼,會(huì)觸發(fā)...
一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過subscribe方法訂閱,api接口如下: 1.1public void subscribe...