01. linux一些常用命令的使用示例 scp命令 假設(shè)有node1、node2、node3三臺(tái)機(jī)器，在/opt/files文件夾下有a.txt、b.txt、c.txt三個(gè)...
發(fā)簡(jiǎn)信
IP屬地：北京
-
01.linux一些常用命令的使用示例
-
02. Java Stream Collectors各種方法使用實(shí)例02.Java Stream Collectors各種方法使用實(shí)例 最近這段時(shí)間一直在學(xué)習(xí)java8的lambda和stream api的使用，在學(xué)習(xí)過(guò)程中發(fā)現(xiàn)collect...
-
01.flume source的實(shí)現(xiàn)方式以及PollableSource的process方法返回值READY和BACKOFF區(qū)別前言 之前公司有一個(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ù)
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)求06. KafkaConsumer是如何處理過(guò)期offset(越界offset)請(qǐng)求 該篇文章是基于以下的條件編寫(xiě)完成的 1. Kafka cluster集群版本0.10.0...
-
01進(jìn)度條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)境安裝配置05.kafka connect Distributed 模式環(huán)境安裝配置 前言： 前段時(shí)間在調(diào)研通過(guò)PostgreSQL Logical Decoding Plug...
-
04. kafka log數(shù)據(jù)清理04. kafka log數(shù)據(jù)清理 前言：前端時(shí)間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼，主要是從整體流程上分析的源碼。今天有一個(gè)同事正好有一個(gè)同事問(wèn)到ka...
-
-
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析 我們?cè)谑褂肒afkaProducer向kafka broker發(fā)送消息時(shí)候，我們都會(huì)有一個(gè)疑問(wèn)prod...
-
02. KafkaConsumer訂閱topic數(shù)據(jù)，是如何實(shí)現(xiàn)加入組以及再平衡原理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...
-
01. KafkaConsumer 訂閱topic數(shù)據(jù)，不通方式的區(qū)別
一. KafkaConsumer訂閱topic數(shù)據(jù)的方式可以分為兩種 1. 通過(guò)subscribe方法訂閱，api接口如下： 1.1public void subscribe...
