kakfa配置參數(shù)Producer的示例分析

這篇文章主要介紹kakfa配置參數(shù)Producer的示例分析，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

serializer.class

默認值： kafka.serializer.DefaultEncoder

必須實現(xiàn)kafka.serializer.Encoder接口，將T類型的對象encode成kafka message

key.serializer.class

默認值：serializer.class

key對象的serializer類

partitioner.class

默認值：kafka.producer.DefaultPartitioner

必須實現(xiàn)kafka.producer.Partitioner，根據(jù)Key提供一個分區(qū)策略

producer.type

默認值：sync

指定消息發(fā)送是同步還是異步。異步asyc成批發(fā)送用kafka.producer.AyncProducer， 同步sync用kafka.producer.SyncProducer

metadata.broker.list

默認值：boker list

使用這個參數(shù)傳入boker和分區(qū)的靜態(tài)信息，如host1:port1,host2:port2, 這個可以是全部boker的一部分

compression.codec

默認值：NoCompressionCodec

消息壓縮，默認不壓縮

compressed.topics

默認值：null

在設(shè)置了壓縮的情況下，可以指定特定的topic壓縮，為指定則全部壓縮

message.send.max.retries

默認值：3

消息發(fā)送最大嘗試次數(shù)

retry.backoff.ms

默認值：300

每次嘗試增加的額外的間隔時間

topic.metadata.refresh.interval.ms

默認值：600000

定期的獲取元數(shù)據(jù)的時間。當分區(qū)丟失，leader不可用時producer也會主動獲取元數(shù)據(jù)，如果為0，則每次發(fā)送完消息就獲取元數(shù)據(jù)，不推薦。如果為負值，則只有在失敗的情況下獲取元數(shù)據(jù)。

queue.buffering.max.ms

默認值：5000

在producer queue的緩存的數(shù)據(jù)最大時間，僅僅for asyc

queue.buffering.max.message

默認值：10000

producer 緩存的消息的最大數(shù)量，僅僅for asyc

queue.enqueue.timeout.ms

默認值：-1

0當queue滿時丟掉，負值是queue滿時block,正值是queue滿時block相應(yīng)的時間，僅僅for asyc

batch.num.messages

默認值：200

一批消息的數(shù)量，僅僅for asyc

request.required.acks

默認值：0

0表示producer毋須等待leader的確認，1代表需要leader確認寫入它的本地log并立即確認，-1代表所有的備份都完成后確認。 僅僅for sync

request.timeout.ms

默認值：10000

確認超時時間

以上是“kakfa配置參數(shù)Producer的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對大家有幫助，更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道！