kafka发送消息的简单理解

必要的配置

• 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 请求超时时间