Does ray currently support some form of streaming, similar to kafka-stream

Does ray currently support some form of streaming, similar to kafka-stream.

We currently have this need. Enter a stream when a user generates a certain behavior, pre-process the data inside the stream, and call the model for prediction.

Does ray currently have this capability?

Looking forward to your response.