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