Support for RocketMQ in KEDA

[vb3328998]

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]

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

[dovics]

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

[zroubalik]

@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: #5797

[dovics]

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(apache/rocketmq-client-go#1167) to see what their community had to say.

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