温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

kakfa配置参数Producer的示例分析

发布时间:2021-12-07 14:35:27 来源:亿速云 阅读:123 作者:小新 栏目:云计算

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

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI