A simple example on how to use Kafka and Nifi. View my Medium post for a more comprehensive explanation.
To-do:
- Add configuration of the processors in Nifi.
The final result will look like this:
NOTE: currently there is an issue with the format at which Nifi publishes the message to Kafka. If you look at the message in the Control Center they look fine. However, as you can see in the screenshot there are additional characters added, this isn't JSON anymore.
This will be looked into later. I'm pretty sure it has to do with the syntax used by the OnRouteContent processor.