一. KafkaConsumer订阅topic数据的方式可以分为两种 1. 通过subscribe方法订阅,api接口如下: 1.1public void subscribe...
IP属地:北京
一. KafkaConsumer订阅topic数据的方式可以分为两种 1. 通过subscribe方法订阅,api接口如下: 1.1public void subscribe...
07. kafka cluster在zk宕机的情况下是否还能提供读写服务 前言: 前段时间公司要对网路中的一台交换机进行维修,由于kafka集群和zk集群之间的通讯要...
06. KafkaConsumer是如何处理过期offset(越界offset)请求 该篇文章是基于以下的条件编写完成的 1. Kafka cluster集群版本0.10.0...
04. kafka log数据清理 前言:前端时间一直在解读kafka0.10.1的客户端和服务器端的源码,主要是从整体流程上分析的源码。今天有一个同事正好有一个同事问到ka...
05.kafka connect Distributed 模式环境安装配置 前言: 前段时间在调研通过PostgreSQL Logical Decoding Plug...
02. KafkaConsumer订阅topic数据,是如何实现加入组以及再平衡原理 上一篇在分析Consumer不通订阅方式的时候,提到了同一消费组下有多个消费者时,会触发...