# 概览

Kafka生产者

  • 是否允许丢?
  • 是否允许重?
  • 延迟和吞吐量?

# 创建 Kafka 生产者

# 必选配置

  • bootstrap.servers
  • key.serializer
  • value.serializer

# 消息发送方式

  • 发送并忘记
  • 同步发送
  • 异步发送

# 消息发送参数

  • topic
  • partition
  • key
  • value

# 其他配置

  • acks,0、1、all
  • buffer.memory
  • compression.type
  • retries
  • batch.size
  • linger.ms
  • client.id
  • max.in.flight.requests.per.connection
  • timeout.msrequest.timeout.msmetadata.fetch.timeout.ms
  • max.block.ms
  • max.request.size
  • receive.buffer.bytes、send.buffer.bytes

# 序列化器

  • 自定义序列化器
  • Avro 序列化

# 分区

  • 不指定 key,默认使用轮训算法
  • 指定 key,默认使用散列算法
  • 自定义分区策略