「 文章 」 五月 25, 2023
kafka(二) 生产者
文章字数 1.1k 阅读约需 1 mins.
序列化ProducerRecord.
如果ProducerRecord中指定了Partition.则分区器(Partitioner)不做任何事情.否则分区器根据消息的key得到一个Partition。
消息被添加到相应的batch中,独立的线程将这些batch发送到broker上.
broker收到消息会返回一个响应.
成功写入返回RecordMetaData对象,包含了Topic信息、Patition信息、消息在Partition中的Offset信息.
失败会返回错误. 生产者收...