If anyone has done real-time, please take a look at: https://github.com/apache/pulsar/discussions/22236 This is the last thing I need to complete. Otherwise I have achieved all but one of my goals. Next working with a sink. But I don’t foresee that to be an issue.