librdkafka和Broker版本相容

2021-09-27 05:35:04 字數 939 閱讀 5413

摘自:

自從發布了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安裝步驟

步驟一 configure 步驟二 make 步驟三 sudo make install 1 步驟一可能會出現.configure command not found 解決辦法 chmod 777 configure,由於configure沒有執行許可權,所以修改一下執行許可權就行 2 步驟二可能會...

移植庫librdkafka到openwrt

1,建目錄 feeds packages libs librdkafka 2,在該目錄下建立makefile this is free software,licensed under the gnu general public license v2.see license for more inf...

librdkafka 配置相關原始碼閱讀筆記

支援配置項介紹 相關api name 配置項的名稱,例如 queue.buffering.max.messages type 配置項的取值型別,例如字串 整型等。這是乙個列舉,其定義如下 define rk field offsetof rd kafka conf t,field define rk...