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的示例分析”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！