1.agent上报到kafka metric topic的数据格式有问题，多了collectexpire字段，导致flink无法处理该数据，导致指标在kafka中无法消费
2.处理后上报到kafka metric to druid的数据有问题，value type为空，无法判断该指标是数值型、还是字符型，druid不知道把该数据放在哪个datasource,导致task变为unhealthy状态，failed 无法存入数据。
3.服务器内存不够，kafka占用内存过高，可以通过改启动脚本jvm堆参数，降低使用内存，-Xmx5G -Xms5G
https://cloud.tencent.com/developer/ask/193669
原文：https://www.cnblogs.com/Agnes1994/p/12368345.html