本篇文章為大家展示了librdkafka和Broker版本兼容的示例分析，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

成都創(chuàng)新互聯(lián)公司專(zhuān)注于中大型企業(yè)的做網(wǎng)站、網(wǎng)站建設(shè)和網(wǎng)站改版、網(wǎng)站營(yíng)銷(xiāo)服務(wù)，追求商業(yè)策劃與數(shù)據(jù)分析、創(chuàng)意藝術(shù)與技術(shù)開(kāi)發(fā)的融合，累計(jì)客戶(hù)上千，服務(wù)滿(mǎn)意度達(dá)97%。幫助廣大客戶(hù)順利對(duì)接上互聯(lián)網(wǎng)浪潮，準(zhǔn)確優(yōu)選出符合自己需要的互聯(lián)網(wǎng)運(yùn)用，我們將一直專(zhuān)注品牌網(wǎng)站設(shè)計(jì)和互聯(lián)網(wǎng)程序開(kāi)發(fā)，在前進(jìn)的路上，與客戶(hù)一起成長(zhǎng)！

自從發(fā)布了0.8.0.0.0版本之后，librdkafka支持所有的發(fā)布版本的Apache Kafka broker,但不是所有的語(yǔ)法屬性都能被broker接受，因?yàn)?br/>一些語(yǔ)法特性依賴(lài)于broker的具體實(shí)現(xiàn)

當(dāng)前的默認(rèn)配置:
api.version.request=true
broker.version.fallback=0.9.0.0
api.version.fallback.ms=0 (never revert to broker.version.fallback)

根據(jù)現(xiàn)場(chǎng)使用的broker版本，對(duì)librdkafka進(jìn)行具體的配置

Broker version >= 0.10.0.0 (or trunk)
對(duì)于 librdkafka >= v1.0.0 不再需要配置api.version相關(guān)參數(shù)
對(duì)于 librdkafka < v1.0.0需要指定配置如下：
api.version.request=true
api.version.fallback.ms=0

Broker versions 0.9.0.x

api.version.request=false
broker.version.fallback=0.9.0.x  (the exact 0.9.0.. version you are using)

Broker versions 0.8.x.y
api.version.request=false
broker.version.fallback=0.8.x.y  (your exact 0.8... broker version)

詳情描述
Apache Kafka 在0.10.0.0版本支持KIP-35（提供API函數(shù)查詢(xún)要求的類(lèi)型和支持的版本），
（允許客戶(hù)端查詢(xún)哪些操作合法），對(duì)于舊版本的broker無(wú)法得知是否支持

上述內(nèi)容就是librdkafka和Broker版本兼容的示例分析，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。