其中PARTNUM为topic的partition的数目,这样保证批量发送的数据均匀的落在kafka的partition中。

kafka-python批量发送数据的实例