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

开发者社区> 问答> 正文

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

赵慧 2019-01-22 18:42:40 1352

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

消息中间件 监控 Kafka API 流计算
分享到
取消 提交回答
全部回答(1)
  • 赵慧
    2019-07-17 23:26:23

    刘金辉:Flink应用后台你可以自己配置监控 里面有监控kafka offect的 不需要自己去实现。你把他的接口抽出来 放在你自己的客户端 应该也可以

    0 0
微服务
使用钉钉扫一扫加入圈子
+ 订阅

构建可靠、高效、易扩展的技术基石

推荐文章
相似问题