必要的配置
- servers服务的集群
- key和value的serializer
线程安全的生产者类KafkaProducer
- 发送的三种模型
- 发后既忘
- 同步
- 异步
消息对象
实际发送的kafka消息对象ProducerRecord
- 对象的属性
- topic主题
- partion分区
- haders消息头
- Key 键
- Value 值
- timestamp时间戳消息发送前的操作序列化
- key,value的序列化 分区器
- 分区 生产者拦截器
- onSend发送拦截
- onAcknowledgement回调前的逻辑
整体结构图
重要参数
- Acks 1 主节点写入的消息即可 0 不需等待响应 -1 所有节点响应
- max.request.size 最大1M
- retries重试次数和retry.backoff.ms消息之间的间隔
- linger.ms生产者发送消息之前等待多长时间，默认0
- receive和send buffer.bytes 缓冲区大小
- request.timeout 请求超时时间
