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