请教大家一个问题,请教大家一个问题,我们在应用里面使用了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 3256 1

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

取消 提交回答
全部回答(1)
  • 赵慧@ApacheFlink中文社区
    2019-07-17 23:26:23

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

    0 0
相关问答

1

回答

kafka中的max.in.flight.requests.per.connection是什么意思?

2021-12-09 18:53:57 419浏览量 回答数 1

1

回答

Spark程序中使用SQL语句验证Schema的方法是什么?

2021-12-09 20:15:07 83浏览量 回答数 1

1

回答

单流的一条数据,需要先sink 至mysql,再sink至kafka,并保证两sink的原子性以及s

2021-12-07 16:06:16 314浏览量 回答数 1

1

回答

flink kafka SQL Connectors 传递kerberos 参数

2021-12-06 22:01:45 394浏览量 回答数 1

1

回答

单流的一条数据,需要先sink 至mysql,再sink至kafka,并保证两sink的原子性以及s

2021-12-06 15:30:01 392浏览量 回答数 1

1

回答

Flink CDC connectors 替换 Debezium+Kafka 的数据采集模块, 实现

2021-11-24 19:18:30 1008浏览量 回答数 1

1

回答

JAVA中Ex t e rn a l i z a b l e 继 承 了 Se r i a l iz

2021-11-16 23:50:51 327浏览量 回答数 1

1

回答

请问用flink-sql写kafka发送Avro类型数据怎么定义avro schema的#Flink

2021-01-24 09:50:49 1709浏览量 回答数 1

1

回答

如何使用sql来查看某个表的DDL语句?#PG

2020-06-10 18:41:32 874浏览量 回答数 1

2

回答

请问flink on yarn模式, 怎么使用REST API接口对作业进行监控? 我想集成到自己的后台里 而不是在原本的web UI上查看

2019-02-21 16:50:47 7907浏览量 回答数 2
17
文章
349
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载