标签:
-- Topic (名字) -- PartitionID ( 可选) -- Key[( 可选 ) -- Value
<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不起作用,代码逻辑决定)
针对3,提供三种构造函数形参: -- ProducerRecord(topic, partition, key, value) -- ProducerRecord(topic, key, value) -- ProducerRecord(topic, value)
针对3,提供三种构造函数形参:
-- ProducerRecord(topic, partition, key, value)
-- ProducerRecord(topic, key, value)
-- ProducerRecord(topic, value)
Kafka源码中的Producer Record定义
原文地址:http://www.cnblogs.com/tonychai/p/4528190.html