关于Kafka(四) 生产者

发送消息 > 创建ProducerRecord对象,包含主题和内容,分区和键可选 > 序列化器将对象序列化以便网络传输  > 数据传输到分区器,如果在ProducerRecord中指定了分区,则直接继续发送,若未指定分区,则根据对象的键选择分区 > 相同分区分到同一个消息批次中,并发送给服务器 > 服务器接收到消息后返回响应,如果成功写入则返回RecordMetaData对象,包含主题和分区信息,
相关文章
相关标签/搜索