开发者社区> 问答> 正文

请教大家一个问题,请教大家一个问题,我们在应用里面使用了KafkaConnector 然后现在要对kafka里面的每个topic的一些特征数据做一些简单的监控,现在的思路是基于Flink 的system metrics 但是我大概看了一下官方的文档,和Flink 里面FlinkKafkaConsumerBase的open方法和run方法的实现,暂时没有找到获取kafka topic相关的信息的API,大家有这方面的经验吗?

转自钉钉群21789141:请教大家一个问题,请教大家一个问题,我们在应用里面使用了KafkaConnector 然后现在要对kafka里面的每个topic的一些特征数据做一些简单的监控,现在的思路是基于Flink 的system metrics 但是我大概看了一下官方的文档,和Flink 里面FlinkKafkaConsumerBase的open方法和run方法的实现,暂时没有找到获取kafka topic相关的信息的API,大家有这方面的经验吗?

展开
收起
赵慧@ApacheFlink中文社区 2019-01-22 18:42:40 3722 0
1 条回答
写回答
取消 提交回答
  • 刘金辉:Flink应用后台你可以自己配置监控 里面有监控kafka offect的 不需要自己去实现。你把他的接口抽出来 放在你自己的客户端 应该也可以

    2019-07-17 23:26:23
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
CUDA MATH API 立即下载
API PLAYBOOK 立即下载
传统企业的“+互联网”-API服务在京东方的实践 立即下载