我正在使用flink消费kafka并写入redis。这是我的redis接收函数:.addSink(newRichSinkFunction(){@Overridepublicvoidinvoke(MobilePageEventevent,Contextcontext){JEDIS_CLUSTER.zadd(..);}}).name("redissink");虽然我可以从redis命令行获取数据，但指标显示sink函数的输出为零:我怎样才能增加这个指标？ 最佳答案 numRecordsIn和numRecordsOut指标仅计算在Flin