core-async

2025-10-14T12:04:42.199369Z

are there any core.async integrations with rabbitmq or kafka?

phronmophobic 2025-10-14T18:40:46.581759Z

Looking on https://phronmophobic.github.io/dewey/search.html, I could only find https://github.com/AppsFlyer/ketu

Ben Sless 2025-10-15T09:36:00.924469Z

Last time I checked, there's a subtle oversight in Ketu where subscriptions aren't paused after polling. You might also want to handle partitions more carefully

Reut Sharabani 2025-10-15T13:09:58.648519Z

For Kafka ketu is proven to work at scale if that's a requirement. But I would also check just using the Java API (I did it maybe a year ago and it wasn't too hard). IDK about RabbitMQ but I'd bet the Java API is also very usable from clojure there.

2025-10-16T01:05:16.637879Z

thanks!