Producing and Consuming Pulsar messages with Apache NiFi

Thanks to Pulsar committer and Author, David Kjerrumgaard, we have a brand new advanced feature Apache NiFi 1.14/1.15 record processor for consuming and producing messages from StreamNative Cloud and any other Apache Pulsar cluster. I recommend utilizing the latest Apache NiFi 1.15 with Apache Pulsar 2.8.1.

Official First NAR Release

Connector
https://github.com/david-streamlio/pulsar-nifi-bundle

References

• https://www.datainmotion.dev/2019/08/gtfs-real-time-streaming-with-apache.html
• https://github.com/tspannhw/SpeakerProfile/tree/main/2021/talks
• https://www.youtube.com/watch?v=pfhoF3yTdHU
• https://www.slideshare.net/bunkertor/using-flip-with-influxdb-for-edgeai-iot-at-scale