(2)Kafka中生产者工作机制

1.生产者分区机制

(1)分区原因

提高可扩展性：集群可通过设置Topic的Partition数量，以适应合适大小的数据。

提高并发：以Partition为单位读写。

(2)数据分区原则

    ①直接指明partition值

    ②不执行partition，而
通过key-value，进行
哈希取余得到partition

    ③
轮询算法：只有value时，随机生成一个整数值，与Topic可用的partition数量取余。

 
2.生产者可靠性保证

(1)可靠性保证机制

    为了保证生产者能可靠的发送到指定的 topic，
topic 的每个partition 收到
生产者发送的数据后，都需要向生产者发送 ack（acknowledgement 确认收到）
，如果
producer 收到 ack，就会进行下一轮的发送，否则重新发送数据。

(2)Kafka中生产者工作机制最先出现在Python成神之路。