1.生产者同步发送消息

如果⽣产者发送消息没有收到ack，⽣产者会阻塞，阻塞到3s的时间，如果还没有收到消息，
会进⾏重试。重试的次数3次。

2.生产者异步发送消息

异步发送，生产者发送完消息后就可以执行之后的业务，broker在收到消息后异步调用生产
者提供的callback回调方法。

3.生产者中ack的配置

在同步发送的前提下，⽣产者在获得集群返回的ack之前会⼀直阻塞。那么集群什么时候返回
ack呢？此时ack有3个配置：

• ack = 0 kafka-cluster不需要任何的broker收到消息，就⽴即返回ack给⽣产者，最容易 丢消息的，效率是最⾼的。

• ack=1（默认）： 多副本之间的leader已经收到消息，并把消息写⼊到本地的log中，才 会返回ack给⽣产者，性能和安全性是最均衡的。

• ack=-1/all。⾥⾯有默认的配置min.insync.replicas=2(默认为1，推荐配置⼤于等于2)， 此时就需要leader和⼀个follower同步完后，才会返回ack给⽣产者（此时集群中有2个broker已完成数据的接收），这种⽅式最安全，但性能最差。

4.关于消息发送的缓冲区

• kafka默认会创建⼀个消息缓冲区，⽤来存放要发送的消息，缓冲区是32m。
• kafka本地线程会去缓冲区中⼀次拉16k的数据，发送到broker。
• 如果线程拉不到16k的数据，间隔10ms也会将已拉到的数据发到broker。