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