Kafka 权威指南--Kafka 生产者

概览

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.ms、request.timeout.ms、metadata.fetch.timeout.ms
  • max.block.ms
  • max.request.size
  • receive.buffer.bytes、send.buffer.bytes

序列化器

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

分区

  • 不指定 key,默认使用轮训算法
  • 指定 key,默认使用散列算法
  • 自定义分区策略
-------------本文结束感谢您的阅读-------------

本文标题:Kafka 权威指南--Kafka 生产者

文章作者:

发布时间:2019年12月21日 - 00:12

最后更新:2021年12月20日 - 16:12

原始链接:http://huihui.couplecoders.tech/2019/2EB78WN/

许可协议: 署名-非商业性使用-禁止演绎 4.0 国际 转载请保留原文链接及作者。