Kafka-生产者

文章目录 1. 发送消息主要步骤 2. 发送消息 3. 生产者核心配置参数 4. 分区策略 5. TCP连接 1. 发送消息主要步骤 ProduceRecord对象包含了目标主题和消息内容，也可以额外指定消息键或者分区。调用send()方法后，序列化器首先将消息和键序列化成字节数组，随后将数据传递给分区器。分区器的默认分区策略是：轮询+按键哈希映射。确认分区之后，消息被加入到该分区的一个批次之中，

>>阅读原文<<