search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Feature new metrics #84

Open ArthurWrong opened 1 year ago

ArthurWrong commented 1 year ago
  1. According to FLIP-33, I replace tpsMetric and outTps with numRecordsInPerSecond and numRecordsOutPerSecond, and replace their counter with numRecordsIn and numRecordsOut at the same time.
  2. Additionally, numRecordsIn, numRecordsOut, numRecordsInPerSecond, numRecordsOutPerSecond, these four metrics can be monitored on aliyun vvp.
lizhimins commented 3 months ago

Thanks for your contributions! Can you rebase to last main branch.

ArthurWrong commented 3 months ago

Thanks for your contributions! Can you rebase to last main branch.

Done.

ArthurWrong commented 2 months ago

@lizhimins @humkum Can we review the code and merge it into the main branch？