您好,登錄后才能下訂單哦!
https://github.com/edenhill/librdkafka/issues/1660
RT,公司的kafka更換了版本, 用到librdkafka的場景就開始報這條警告
解決方式如下:
在初始化的時候,修改相關配置
const char* api_version_request = "false"; const char* api_version_fallback = "0.8.2.0"; if (rd_kafka_conf_set(g_rkconf, "api.version.request", api_version_request, errstr, sizeof(errstr)) != RD_KAFKA_CONF_OK) { fprintf(stderr, "%s\n", errstr); exit(0); } if (rd_kafka_conf_set(g_rkconf, "broker.version.fallback", api_version_fallback, errstr, sizeof(errstr)) != RD_KAFKA_CONF_OK) { fprintf(stderr, "%s\n", errstr); exit(0); }
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。