New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

#

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Jump to bottom

fix: [inputs/rocketmq] 修复 msgDiff queue维度聚合逻辑 #741

Merged

kongfei605 merged 1 commit into flashcatcloud:main from katepangLiu:main

Dec 22, 2023

Contributor

katepangLiu commented Dec 21, 2023

按queue维度聚合，聚合的key 应该为 brokerName + ":" + fmt.Sprint(queueId)


          fix: [inputs/rocketmq] 修复 msgDiff queue维度聚合逻辑

1f9021b

Collaborator

kongfei605 commented Dec 22, 2023

Thank you @katepangLiu

kongfei605 merged commit 85f7b79 into flashcatcloud:main

# for free to join this conversation on GitHub. Already have an account? # to comment

Labels

None yet