kafka: 基础概念回顾（生产者客户端和机架感知相关内容）

一、kafka生产者客户端

在Kafka架构中存在若干关键性概念：

• Producer：消息发布者，其主要职责是生成数据信息，并将其发送至Kafka broker的指定分区位置
• Consumer：消息订阅者，其核心功能是从Kafka多个分区中获取并处理相关数据
• Broker：作为Kafka服务的核心节点，承担着消息存储与传输的重要作用

1、整体架构：数据发送流程

（1）生产者

• 拦截器
  在消息发送至目标之前，生产者所配置的拦截器能够执行特定操作，对数据内容实施必要的处理流程，例如实现消息的筛选、调整信息的具体内容等。

    package org.apache.kafka.clients.producer;
    import org.apache.kafka.common.Configurable;
    public interface ProducerInterceptor<K, V> extends Configurable {
    		//在将消息序列化和计算分区之前会调⽤该⽅法