我正在使用flink消费kafka并写入redis。
下面是我对redis的接收器函数:
.addSink(new RichSinkFunction<MobilePageEvent>() {
@Override
public void invoke(MobilePageEvent event, Context context) {
JEDIS_CLUSTER.zadd(..);
}
})
.name("redis sink");
虽然我可以从redis命令行中获取数据,但指标显示汇函数的输出为零:
如何增加此指标?
https://stackoverflow.com/questions/54928734
复制相似问题