Ray Async actors and Apache Kafka

Ray Core
1

N@@B at work here.

Thank you for this awesome package.

I am planning to use Ray Async actors as consumers of Apache kafka enabled Azure EventHubs. Idea is to capture event streams in batch mode and process them.
Was wondering if anyone had attempted this integration and any reference or sample code (any event driven implementation) would be would be of great help.

Any advice on the approach in general is welcome. Kindly help.

2

Haven’t tried before. But since Ray will work well with any python packages, you can probably just use the Kafka consumer python packages? Have you tried this?