superfly / fly-autoscaler

A metrics-based autoscaler for Fly.io
Apache License 2.0
28 stars 4 forks source link

Kafka metric collector #17

Open benbjohnson opened 9 months ago

benbjohnson commented 9 months ago

We should add support for Kafka as a metric collector using the Kafka Go Client. We should be able to determine the queue depth based on the consumer group commit & offset.

gedw99 commented 7 months ago

Hey Ben

any opportunity for NATS too ?

this package is really well done btw

benbjohnson commented 7 months ago

hey @gedw99! Thanks! Yeah, I think we could add NATS pretty easily. I added a separate issue (#26) to track it.