三个必选项
key.serializer 数据写入key的序列化器默认值没有参数为 org.apache.kafka.common.serialization.Serializer 接口的实现类String类型可以用org.apache.kafka.common.serialization.StringSerializer
value.serializer 数据写入value的序列化器默认值没有参数可以为 org.apache.kafka.common.serialization.Serializer接口的实现类String类型可以用 org.apache.kafka.common.serialization.StringSerializer
bootstrap.servers broker机器的地址
其他为可选项
buffer.memory 生产者客户端可以使用的内存总大小,不仅限于消息大小,比如压缩算法占用的内存也计算在其中默认值 33554432 (32M)
compression.type 生产者生成数据的压缩类型默认值 none可选参数 none、gzip、snappy、lz4或zstd
batch.size 批大小 将一批发往同一分区的数据的最大值默认值 16384 (16KB)
linger.ms 生产者在发送批次前等待更多消息加入批次的时间默认值0
acks 数据同步的应答默认参数 all可选参数 0:渣男模式,只要发送数据就认为成功1:leader分区写入数据成功-1/all:暖男模式,leader分区写入数据成功以及所有的follower分区同步数据成功 要结合retries使用
retries 设置数据写入的重试次数默认值 2147483647可选参数 [0,...,2147483647]
request.timeout.ms 请求超时时间默认值 30000(30s)