240 投稿
收录了6篇文章 · 1人关注
  • kafka_06_生产者拦截器

    Kafka中的拦截器(Interceptor)是0.10.x.x版本引入的一个功能,一共有两种:Kafka Producer端的拦截器和Kafk...

  • kafka_05_Kafka的分区器

    Kafka 分区器 我们知道,Kafka中的每个Topic一般会分配N个Partition,那么生产者(Producer)在将消息记录(Prod...

  • Resize,w 360,h 240
    kafka_04_Kafka的序列化和反序列化

    序列化 kafka自带的序列化器都实现了org.apache.kafka.common.serialization.Serializer接口 该...

  • Resize,w 360,h 240
    kafka_03_Kafka消息发送

    Kafka消息发送 1. 构建ProducerRecord对象 该类如下: 这里有5个构造方法,但是最后用的就是其中的一个。实际应用中,构建Pr...

  • kafka_02_kafka快速入门案例

    使用Java代码编写创建springboot项目,gradle工程依赖如下: 生产者客户端如下(注意看注释): 消费者客户端如下: 执行结果如下...

  • kafka_01_kafka集群的安装

    服务器列表如下,并配置免密登陆 1.安装jdk ,并配置环境变量,略去 2. 安装zookeeper 集群 master节点: 三台服务器配置z...

专题公告

学习笔记