当前位置 : 主页 > 大数据 > 区块链 >

解决librdkafka 报WARN:Protocol read buffer underflow

来源:互联网 收集:自由互联 发布时间:2021-06-22
https://github.com/edenhill/librdkafka/issues/1660 RT,公司的kafka更换了版本, 用到librdkafka的场景就开始报这条警告 解决方式如下: 在初始化的时候,修改相关配置 constchar*api_version_request="false

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);
}
网友评论