01. linux一些常用命令的使用示例 scp命令 假设有node1、node2、node3三台机器,在/opt/files文件夹下有a.txt、b.txt、c.txt三个...
01. linux一些常用命令的使用示例 scp命令 假设有node1、node2、node3三台机器,在/opt/files文件夹下有a.txt、b.txt、c.txt三个...
02.Java Stream Collectors各种方法使用实例 最近这段时间一直在学习java8的lambda和stream api的使用,在学习过程中发现collect...
前言 之前公司有一个需求要实现把rocketmq和rabbitmq中的数据对接到kafka中,虽然flume中已经提供了很多种类的source,但是没有提供rocke...
07. kafka cluster在zk宕机的情况下是否还能提供读写服务 前言: 前段时间公司要对网路中的一台交换机进行维修,由于kafka集群和zk集群之间的通讯要...
06. KafkaConsumer是如何处理过期offset(越界offset)请求 该篇文章是基于以下的条件编写完成的 1. Kafka cluster集群版本0.10.0...
01进度条 前提: 在平时做开发是遇到一个这样的问题,有一个初始化操作比较耗时,如果做成同步实现,前端的http请求会超时,因此做成了异步实现,前端提交请求后,就返回...
05.kafka connect Distributed 模式环境安装配置 前言: 前段时间在调研通过PostgreSQL Logical Decoding Plug...
04. kafka log数据清理 前言:前端时间一直在解读kafka0.10.1的客户端和服务器端的源码,主要是从整体流程上分析的源码。今天有一个同事正好有一个同事问到ka...
03. KafkaProducer 是如何从服务器获取元数据的原理分析 我们在使用KafkaProducer向kafka broker发送消息时候,我们都会有一个疑问prod...
02. KafkaConsumer订阅topic数据,是如何实现加入组以及再平衡原理 上一篇在分析Consumer不通订阅方式的时候,提到了同一消费组下有多个消费者时,会触发...
@aaagu1234 多谢鼓励,后面会有更详细的文章
01. KafkaConsumer 订阅topic数据,不通方式的区别一. KafkaConsumer订阅topic数据的方式可以分为两种 1. 通过subscribe方法订阅,api接口如下: 1.1public void subscribe...
一. KafkaConsumer订阅topic数据的方式可以分为两种 1. 通过subscribe方法订阅,api接口如下: 1.1public void subscribe...