如何提高发送吞吐量，通过调整一下几个参数来提高吞吐量：
1、批次大小（batch.size）：
设定一个批次数据的大小。生产者会把多个消息放在同一个批次里。
2、阻塞时间（max.block.ms）：
指定生产者在调用send()方法或使用partitionsFor()方法获取元数据时的阻塞时间。
3、等待时间（linger.ms）：
指定生产者在发送批次之前等待更多消息加入批次的时间。
4、缓冲区大小（buffer.memory）：
设置生产者内存缓冲区的大小，即RecordAccumlator消息累加器
5、压缩算法（compression.type）：
默认消息发送时不会被压缩。可以设置的算法：snappy，gzip，lz4。