如何在Flink中增加SinkFunction的numRecordsOutPut指标？
如何在Flink中增加SinkFunction的numRecordsOutPut指标？
提问于 2019-02-28 23:10:21
我正在使用flink消费kafka并写入redis。
下面是我对redis的接收器函数：
.addSink(new RichSinkFunction<MobilePageEvent>() {
@Override
public void invoke(MobilePageEvent event, Context context) {
JEDIS_CLUSTER.zadd(..);
}
})
.name("redis sink");虽然我可以从redis命令行中获取数据，但指标显示汇函数的输出为零：
如何增加此指标？
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54928734
复制相关文章
相似问题
腾讯云开发者
