Kafka中的拦截器(Interceptor)是0.10.x.x版本引入的一个功能,一共有两种:Kafka Pro...[作者空间]
Kafka 分区器 我们知道,Kafka中的每个Topic一般会分配N个Partition,那么生产者(Produ...[作者空间]
序列化 kafka自带的序列化器都实现了org.apache.kafka.common.serialization...[作者空间]
Kafka消息发送 1. 构建ProducerRecord对象 该类如下: 这里有5个构造方法,但是最后用的就是其...[作者空间]
使用Java代码编写创建springboot项目,gradle工程依赖如下: 生产者客户端如下(注意看注释): 消...[作者空间]
服务器列表如下,并配置免密登陆 1.安装jdk ,并配置环境变量,略去 2. 安装zookeeper 集群 mas...[作者空间]