一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過subscribe方法訂閱浸卦，api接口如下： 1.1public void subscribe...
發(fā)簡信
IP屬地：北京
-
01. KafkaConsumer 訂閱topic數(shù)據(jù)，不通方式的區(qū)別
-
07. kafka cluster在zk宕機(jī)的情況下是否還能提供讀寫服務(wù)
07. kafka cluster在zk宕機(jī)的情況下是否還能提供讀寫服務(wù) 前言： 前段時間公司要對網(wǎng)路中的一臺交換機(jī)進(jìn)行維修微驶，由于kafka集群和zk集群之間的通訊要...
-
06. KafkaConsumer是如何處理過期offset(越界offset)請求06. KafkaConsumer是如何處理過期offset(越界offset)請求 該篇文章是基于以下的條件編寫完成的 1. Kafka cluster集群版本0.10.0...
-
04. kafka log數(shù)據(jù)清理04. kafka log數(shù)據(jù)清理 前言：前端時間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼幕侠，主要是從整體流程上分析的源碼呼巷。今天有一個同事正好有一個同事問到ka...
-
05. kafka connect Distributed 模式環(huán)境安裝配置05.kafka connect Distributed 模式環(huán)境安裝配置 前言： 前段時間在調(diào)研通過PostgreSQL Logical Decoding Plug...
-
02. KafkaConsumer訂閱topic數(shù)據(jù)稻扬，是如何實(shí)現(xiàn)加入組以及再平衡原理02. KafkaConsumer訂閱topic數(shù)據(jù)外傅，是如何實(shí)現(xiàn)加入組以及再平衡原理 上一篇在分析Consumer不通訂閱方式的時候蹦哼，提到了同一消費(fèi)組下有多個消費(fèi)者時哪轿，會觸發(fā)...