batch.size

用于指定缓冲区一批数据最大值。

linger.ms

指定如果数据迟迟未达到 batch.size，等待linger.time之后就会发送数据

buffer.memory

RecordAccumulator 缓冲区总大小

acks

0：生产者发送过来的数据，不需要等数据落盘应答。

1：生产者发送过来的数据，Leader收到数据后应答。

-1（all）：生产者发送过来的数据，Leader+和 isr 队列里面的所有节点收齐数据后应答。

max.in.flight.requests.per.connection

允许最多没有返回 ack 的次数，默认为 5，开启幂等性要保证该值是 1-5 的数字。

retry.backoff.ms

当消息发送出现错误的时候，系统会重发消息的重试次数。

compression.type

生产者发送的所有数据的压缩方式。

partition

指定kafka分区。