日喀则网站建设自动发外链工具

1 消息发送

1.1 Kafka Java客户端数据生产流程解析

1 首先要构造一个 ProducerRecord 对象，该对象可以声明主题Topic、分区Partition、键 Key以及值 Value，主题和值是必须要声明的，分区和键可以不用指定。

2 调用send() 方法进行消息发送。

3 因为消息要到网络上进行传输，所以必须进行序列化，序列化器的作用就是把消息的 key value对象序列化成字节数组。

4 接下来数据传到分区器，如果之间的 ProducerRecord 对象指定了分区，那么分区器将不再做任何事，直接把指定的分区返回；如果没有，那么分区器会根据 Key 来选择一个分区，选择好分区之后，生产者就知道该往哪个主题和分区发送记录了。

5 接