Kafka-生产者

Kafka生产者

kafka数据生产流程如图:

  1. 创建一个 ProducerRecord 对象,包括目标主题和要发送的内容
  2. 将对象序列化成字节数组
  3. 数据被传给分区:
    • 是否指定了partition -> 直接到指定分区
    • 是否指定了key -> 分区器使用该 key 进行 hash 操作,然后对 topic 对应的分区数量进行取模操作并返回一个分区。
    • 没有指定key -> 则通过先产生随机数,之后在该数上自增的方式产生一个数,并转为正数之后进行取余操作。
  4. 添加到批次,并发送
  5. 服务器收到消息后返回响应
    • 成功 -> 返回 RecordMetaData对象
    • 失败 -> 返回错误信息
-------- 本文结束 感谢阅读 --------

本文标题:Kafka-生产者

文章作者:Guyuqing

发布时间:2019年06月10日 - 11:38

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

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

坚持技术分享,您的支持将鼓励我继续创作!
0%