发简信
IP属地：北京
-
01.linux一些常用命令的使用示例
01. linux一些常用命令的使用示例 scp命令 假设有node1、node2、node3三台机器，在/opt/files文件夹下有a.tx...
-
02. Java Stream Collectors各种方法使用实例02.Java Stream Collectors各种方法使用实例 最近这段时间一直在学习java8的lambda和stream api的使用，...
-
01.flume source的实现方式以及PollableSource的process方法返回值READY和BACKOFF区别前言 之前公司有一个需求要实现把rocketmq和rabbitmq中的数据对接到kafka中，虽然flume中已经提供了很多种类的sou...
-
07. kafka cluster在zk宕机的情况下是否还能提供读写服务
07. kafka cluster在zk宕机的情况下是否还能提供读写服务 前言： 前段时间公司要对网路中的一台交换机进行维修，由于kaf...
-
06. KafkaConsumer是如何处理过期offset(越界offset)请求06. KafkaConsumer是如何处理过期offset(越界offset)请求 该篇文章是基于以下的条件编写完成的 1. Kafka cl...
-
01进度条01进度条 前提： 在平时做开发是遇到一个这样的问题，有一个初始化操作比较耗时，如果做成同步实现，前端的http请求会超时，因此做成了异...
-
05. kafka connect Distributed 模式环境安装配置05.kafka connect Distributed 模式环境安装配置 前言： 前段时间在调研通过PostgreSQL Logica...
-
04. kafka log数据清理04. kafka log数据清理 前言：前端时间一直在解读kafka0.10.1的客户端和服务器端的源码，主要是从整体流程上分析的源码。今天有...
-
03. KafkaProducer 是如何从服务器获取元数据的原理分析
03. KafkaProducer 是如何从服务器获取元数据的原理分析 我们在使用KafkaProducer向kafka broker发送消息时...