| 关键组件 | 序列化器、分区器、记录累加器（缓冲批次）、Sender 线程 |
|---|---|
| 关键参数 | bootstrap.servers、key/value serializer、acks、retries、linger.ms |
| 幂等 | 开启后重试不会产生重复（同一生产者会话内） |
生产者核心配置
生产者核心配置
bootstrap.servers=kafka1:9092,kafka2:9092
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer
acks=all
enable.idempotence=true
retries=2147483647生产者只需连接部分 Broker 获取元数据，指定两到三个地址即可，不用列全部节点。