一、消息确认机制，生产者发送消息：
acks = 0 ：发送完不等任何服务器响应就认为发送成功
acks = 1：收到一个服务器响应就认为发送成功
acks = all：所有节点都收到，才会收到响应，发送成功。
二、retries(设置重试次数)
//设置重试次数
prop.put(ProducerConfig.RETRIES_CONFIG,10);
生产者从服务器收到的错误有可能是临时性错误，在这种情况下，retries参数的值决定了生产者可以重发消息的次数，如果达到这个次数，生产者会放弃重试返回错误，默认情况下，生产者会在每次重试之间等待100ms
三、消息压缩
默认情况下，消息发送时不会被压缩
//消息压缩
prop.put(ProducerConfig.COMPRESSION_TYPE_CONFIG,"gzip");
使用压缩可以降低网络传输开销和存储开销，而这往往是向 Kafka 发送消息的瓶颈所在。