# 概览
- 是否允许丢?
- 是否允许重?
- 延迟和吞吐量?
# 创建 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.ms、request.timeout.ms、metadata.fetch.timeout.ms
- max.block.ms
- max.request.size
- receive.buffer.bytes、send.buffer.bytes
# 序列化器
- 自定义序列化器
- Avro 序列化
# 分区
- 不指定 key,默认使用轮训算法
- 指定 key,默认使用散列算法
- 自定义分区策略