生产者使用推送模式将消息发布到broker,每条消息都被追加到partition中,属于顺序写磁盘,这种方式提高了Kafka的吞吐率。当producer发送消息到broker时,根据分区算法决定将其存储到哪一个partition。路由机制包括:1. 如果指定了partition,则直接使用;2. 如果未指定partition但指定了key,则通过对key的值进行哈希选择一个partition。