13518219792
这篇文章主要介绍kakfa配置参数Producer的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
创新互联建站是一家集网站建设,息烽企业网站建设,息烽品牌网站建设,网站定制,息烽网站建设报价,网络营销,网络优化,息烽网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。
serializer.class
默认值：kafka.serializer.DefaultEncoder
必须实现kafka.serializer.Encoder接口，将T类型的对象encode成kafka message
key.serializer.class
默认值：serializer.class
key对象的serializer类
partitioner.class
默认值：kafka.producer.DefaultPartitioner
必须实现kafka.producer.Partitioner，根据Key提供一个分区策略
producer.type
默认值：sync
指定消息发送是同步还是异步。异步asyc成批发送用kafka.producer.AyncProducer， 同步sync用kafka.producer.SyncProducer
metadata.broker.list
默认值：boker list
使用这个参数传入boker和分区的静态信息，如host1:port1,host2:port2, 这个可以是全部boker的一部分
compression.codec
默认值：NoCompressionCodec
消息压缩，默认不压缩
compressed.topics
默认值：null
在设置了压缩的情况下，可以指定特定的topic压缩，为指定则全部压缩
message.send.max.retries
默认值：3
消息发送最大尝试次数
retry.backoff.ms
默认值：300
每次尝试增加的额外的间隔时间
topic.metadata.refresh.interval.ms
默认值：600000
定期的获取元数据的时间。当分区丢失，leader不可用时producer也会主动获取元数据，如果为0，则每次发送完消息就获取元数据，不推荐。如果为负值，则只有在失败的情况下获取元数据。
queue.buffering.max.ms
默认值：5000
在producer queue的缓存的数据最大时间，仅仅for asyc
queue.buffering.max.message
默认值：10000
producer 缓存的消息的最大数量，仅仅for asyc
queue.enqueue.timeout.ms
默认值：-1
0当queue满时丢掉，负值是queue满时block,正值是queue满时block相应的时间，仅仅for asyc
batch.num.messages
默认值：200
一批消息的数量，仅仅for asyc
request.required.acks
默认值：0
0表示producer毋须等待leader的确认，1代表需要leader确认写入它的本地log并立即确认，-1代表所有的备份都完成后确认。 仅仅for sync
request.timeout.ms
默认值：10000
确认超时时间
以上是“kakfa配置参数Producer的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注创新互联行业资讯频道！
