search

kedacore / keda

KEDA is a Kubernetes-based Event Driven Autoscaling component. It provides event driven scale for any container running in Kubernetes
https://keda.sh
Apache License 2.0
8.36k stars 1.06k forks source link

Support for RocketMQ in KEDA #6149

Open vb3328998 opened 2 weeks ago

vb3328998 commented 2 weeks ago

Are there any plans to support RocketMQ as a scaler in KEDA? It would be great to have autoscaling based on RocketMQ metrics, similar to the existing scalers for other message queue systems like Kafka.

JorTurFer commented 2 weeks ago

Hey This seems like a nice addition! Are you willing to support it?

dovics commented 1 week ago

Hello @JorTurFer I'm a beginner to keda and want to work on this good-first-issue

zroubalik commented 5 days ago

@dovics great! I will assing this to you.

Here is documentation for adding a new scaler: https://github.com/kedacore/keda/blob/main/CREATE-NEW-SCALER.md Also, please see this issue for a new declarative metadata parsing: https://github.com/kedacore/keda/issues/5797

dovics commented 2 days ago

Hello,

In the past days, I took a look at the rocketmq clients(v4 and v5). They currently lack admin methods and cannot obtain MaxOffset. Although the broker provides related interfaces, it uses a custom protocol implementation. If this part is added to KEDA Medium, maybe a little heavy.

I opened an issue(https://github.com/apache/rocketmq-client-go/issues/1167) to see what their community had to say.

Currently the best way to use rocketmq is probably to use prometheus scaler.