發(fā)簡(jiǎn)信
IP屬地：北京
-
01.linux一些常用命令的使用示例
01. linux一些常用命令的使用示例 scp命令 假設(shè)有node1、node2、node3三臺(tái)機(jī)器，在/opt/files文件夾下有a.tx...
-
02. Java Stream Collectors各種方法使用實(shí)例02.Java Stream Collectors各種方法使用實(shí)例 最近這段時(shí)間一直在學(xué)習(xí)java8的lambda和stream api的使用，...
-
01.flume source的實(shí)現(xiàn)方式以及PollableSource的process方法返回值READY和BACKOFF區(qū)別前言 之前公司有一個(gè)需求要實(shí)現(xiàn)把rocketmq和rabbitmq中的數(shù)據(jù)對(duì)接到kafka中，雖然flume中已經(jīng)提供了很多種類的sou...
-
07. kafka cluster在zk宕機(jī)的情況下是否還能提供讀寫服務(wù)
07. kafka cluster在zk宕機(jī)的情況下是否還能提供讀寫服務(wù) 前言： 前段時(shí)間公司要對(duì)網(wǎng)路中的一臺(tái)交換機(jī)進(jìn)行維修，由于kaf...
-
06. KafkaConsumer是如何處理過期offset(越界offset)請(qǐng)求06. KafkaConsumer是如何處理過期offset(越界offset)請(qǐng)求 該篇文章是基于以下的條件編寫完成的 1. Kafka cl...
-
01進(jìn)度條01進(jìn)度條 前提： 在平時(shí)做開發(fā)是遇到一個(gè)這樣的問題，有一個(gè)初始化操作比較耗時(shí)，如果做成同步實(shí)現(xiàn)，前端的http請(qǐng)求會(huì)超時(shí)，因此做成了異...
-
05. kafka connect Distributed 模式環(huán)境安裝配置05.kafka connect Distributed 模式環(huán)境安裝配置 前言： 前段時(shí)間在調(diào)研通過PostgreSQL Logica...
-
04. kafka log數(shù)據(jù)清理04. kafka log數(shù)據(jù)清理 前言：前端時(shí)間一直在解讀kafka0.10.1的客戶端和服務(wù)器端的源碼，主要是從整體流程上分析的源碼。今天有...
-
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析
03. KafkaProducer 是如何從服務(wù)器獲取元數(shù)據(jù)的原理分析 我們?cè)谑褂肒afkaProducer向kafka broker發(fā)送消息時(shí)...