zoukankan      html  css  js  c++  java
  • Kafka源码中的Producer Record定义

    1.ProducerRecord 含义: 发送给Kafka Broker的key/value 值对
    2.内部数据结构:

    -- Topic (名字)

    -- PartitionID ( 可选)

    -- Key[( 可选 )

    -- Value

    3.生产者记录(简称PR)的发送逻辑:

    <1> 若指定Partition ID,则PR被发送至指定Partition

    <2> 若未指定Partition ID,但指定了Key, PR会按照hasy(key)发送至对应Partition

    <3> 若既未指定Partition ID也没指定Key,PR会按照round-robin模式发送到每个Partition

    <4> 若同时指定了Partition ID和Key, PR只会发送到指定的Partition (Key不起作用,代码逻辑决定)

    4.生产者记录(PR)的实现:

     针对3,提供三种构造函数形参:

    -- ProducerRecord(topic, partition, key, value)

    -- ProducerRecord(topic, key, value)

    -- ProducerRecord(topic, value)

  • 相关阅读:
    [HNOI2013]切糕
    [POI2015]Kinoman
    「NOI2014」动物园
    [ZJOI2006]书架
    [HEOI2015]定价
    bzoj1833 数字计数
    bzoj2565 最长双回文子串
    bzoj4198 荷马史诗
    bzoj1193 马步距离
    bzoj3329 Xorequ
  • 原文地址:https://www.cnblogs.com/tonychai/p/4528190.html
Copyright © 2011-2022 走看看