您好,登錄后才能下訂單哦!
本篇文章為大家展示了librdkafka和Broker版本兼容的示例分析,內容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細介紹希望你能有所收獲。
自從發布了0.8.0.0.0版本之后,librdkafka支持所有的發布版本的Apache Kafka broker,但不是所有的語法屬性都能被broker接受,因為
一些語法特性依賴于broker的具體實現
當前的默認配置:
api.version.request=true
broker.version.fallback=0.9.0.0
api.version.fallback.ms=0 (never revert to broker.version.fallback)
根據現場使用的broker版本,對librdkafka進行具體的配置
Broker version >= 0.10.0.0 (or trunk)
對于 librdkafka >= v1.0.0 不再需要配置api.version相關參數
對于 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函數查詢要求的類型和支持的版本),
(允許客戶端查詢哪些操作合法),對于舊版本的broker無法得知是否支持
上述內容就是librdkafka和Broker版本兼容的示例分析,你們學到知識或技能了嗎?如果還想學到更多技能或者豐富自己的知識儲備,歡迎關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。