01. linux一些常用命令的使用示例 scp命令 假設(shè)有node1、node2、node3三臺(tái)機(jī)器,在/opt/files文件夾下有a.txt、b.txt、c.txt三個(gè)...
01. linux一些常用命令的使用示例 scp命令 假設(shè)有node1、node2、node3三臺(tái)機(jī)器,在/opt/files文件夾下有a.txt、b.txt、c.txt三個(gè)...
02.Java Stream Collectors各種方法使用實(shí)例 最近這段時(shí)間一直在學(xué)習(xí)java8的lambda和stream api的使用,在學(xué)習(xí)過(guò)程中發(fā)現(xiàn)collect...
前言 之前公司有一個(gè)需求要實(shí)現(xiàn)把rocketmq和rabbitmq中的數(shù)據(jù)對(duì)接到kafka中,雖然flume中已經(jīng)提供了很多種類(lèi)的source,但是沒(méi)有提供rocke...
07. kafka cluster在zk宕機(jī)的情況下是否還能提供讀寫(xiě)服務(wù) 前言: 前段時(shí)間公司要對(duì)網(wǎng)路中的一臺(tái)交換機(jī)進(jìn)行維修,由于kafka集群和zk集群之間的通訊要...
06. KafkaConsumer是如何處理過(guò)期offset(越界offset)請(qǐng)求 該篇文章是基于以下的條件編寫(xiě)完成的 1. Kafka cluster集群版本0.10.0...
01進(jìn)度條 前提: 在平時(shí)做開(kāi)發(fā)是遇到一個(gè)這樣的問(wèn)題,有一個(gè)初始化操作比較耗時(shí),如果做成同步實(shí)現(xiàn),前端的http請(qǐng)求會(huì)超時(shí),因此做成了異步實(shí)現(xiàn),前端提交請(qǐng)求后,就返回...
05.kafka connect Distributed 模式環(huán)境安裝配置 前言: 前段時(shí)間在調(diào)研通過(guò)PostgreSQL Logical Decoding Plug...
04. kafka log數(shù)據(jù)清理 前言:前端時(shí)間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼,主要是從整體流程上分析的源碼。今天有一個(gè)同事正好有一個(gè)同事問(wèn)到ka...
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析 我們?cè)谑褂肒afkaProducer向kafka broker發(fā)送消息時(shí)候,我們都會(huì)有一個(gè)疑問(wèn)prod...
02. KafkaConsumer訂閱topic數(shù)據(jù),是如何實(shí)現(xiàn)加入組以及再平衡原理 上一篇在分析Consumer不通訂閱方式的時(shí)候,提到了同一消費(fèi)組下有多個(gè)消費(fèi)者時(shí),會(huì)觸發(fā)...
@aaagu1234 多謝鼓勵(lì),后面會(huì)有更詳細(xì)的文章
01. KafkaConsumer 訂閱topic數(shù)據(jù),不通方式的區(qū)別一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過(guò)subscribe方法訂閱,api接口如下: 1.1public void subscribe...
一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過(guò)subscribe方法訂閱,api接口如下: 1.1public void subscribe...