生产者_发送数据原理剖析一-【官方】百战程序员_IT在线教育培训机构

参数	默认值	作用描述
bootstrap.servers	node2:9092 [,node3:9092] [,node4:9092]	生产者连接集群所需的 broker 地址清单,一个或多个（逗号隔开）
key.serializer		指定发送消息的 key 的序列化类型。一定要写全类名
value.serializer		指定发送消息的value 的序列化类型。一定要写全类名
buffer.memory	32M	RecordAccumulator缓冲区总大小
batch.size	16K	缓冲区一批数据最大值,适当增加该值可以提高吞吐量，但是如果该值设置太大，会导致数据输延迟增加
linger.ms	0ms（表示没有延迟）	如果数据迟迟未达到 batch.size，sender 等待 linger.time之后就会发送数据，单位 ms。生产环境建议该值大小为 5-100ms 之间。
acks	-1	0：生产者发送过来的数据，不需要等数据落盘应答。 1：生产者发送过来的数据，Leader 收到数据后应答。 -1（all）：生产者发送过来的数据，Leader+和 isr 队列里面的所有节点收齐数据后应答。
max.in.flight.requests. per.connection	5	允许最多没有返回 ack 的次数，开启幂等性,要保证该值是 1-5 的数字
enable.idempotence	true	是否开启幂等性，默认开启幂等性。
retries	默认是 int 最大值，2147483647	当消息发送出现错误的时候，系统会重发消息。retries 表示重试次数。如果设置了重试，还想保证消息的有序性，需要设置MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION=1 否则在重试此失败消息的时候，其他的消息可能发送成功了。
retry.backoff.ms	100ms	两次重试之间的时间间隔
compression.type	none	生产者发送的所有数据的压缩方式。默认是不压缩。支持压缩类型：none、gzip、snappy、lz4 和 zstd。

Kafka入门_消息发送和接收生产者_发送数据原理剖析二

北京市昌平区回龙观镇南店村综合商业楼2楼226室