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); }
解决librdkafka 报WARN:Protocol read buffer underflow
原文:http://blog.51cto.com/zhweizhi/2093949