kakfa配置参数Producer的示例分析

这篇文章主要介绍 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 的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注丸趣 TV 行业资讯频道！