一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過subscribe方法訂閱，api接口如下： 1.1public void subscribe...
發(fā)簡信
IP屬地：北京
-
01. KafkaConsumer 訂閱topic數(shù)據(jù)，不通方式的區(qū)別
-
07. kafka cluster在zk宕機的情況下是否還能提供讀寫服務
07. kafka cluster在zk宕機的情況下是否還能提供讀寫服務 前言： 前段時間公司要對網(wǎng)路中的一臺交換機進行維修，由于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的客戶端和服務器端的源碼，主要是從整體流程上分析的源碼。今天有一個同事正好有一個同事問到ka...
-
05. kafka connect Distributed 模式環(huán)境安裝配置05.kafka connect Distributed 模式環(huán)境安裝配置 前言： 前段時間在調(diào)研通過PostgreSQL Logical Decoding Plug...
-
02. KafkaConsumer訂閱topic數(shù)據(jù)，是如何實現(xiàn)加入組以及再平衡原理02. KafkaConsumer訂閱topic數(shù)據(jù)，是如何實現(xiàn)加入組以及再平衡原理 上一篇在分析Consumer不通訂閱方式的時候，提到了同一消費組下有多個消費者時，會觸發(fā)...