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

創(chuàng)新互聯建站是一家集網站建設,息烽企業(yè)網站建設,息烽品牌網站建設,網站定制,息烽網站建設報價,網絡營銷,網絡優(yōu)化,息烽網站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯網需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網站。

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提供一個分區(qū)策略

producer.type

默認值：sync

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

metadata.broker.list

默認值：boker list

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

compression.codec

默認值：NoCompressionCodec

消息壓縮，默認不壓縮

compressed.topics

默認值：null

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

message.send.max.retries

默認值：3

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

retry.backoff.ms

默認值：300

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

topic.metadata.refresh.interval.ms

默認值：600000

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

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的示例分析”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注創(chuàng)新互聯行業(yè)資訊頻道！

本文名稱：kakfa配置參數Producer的示例分析
文章源于：http://chinadenli.net/article28/gdgejp.html

成都網站建設公司_創(chuàng)新互聯，為您提供企業(yè)網站制作、企業(yè)建站、網站建設、動態(tài)網站、響應式網站、微信公眾號

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯