Apache-Nifi-Kafka

This project is an example that shows how it's possible to connect Apache Nifi with Kafka to consume messages from Kafka and produce messages to Kafka. A COVID-19 API was used for this example.

Architecture of the project

Prerequisites

Docker
Docker Compose

Implementation

Clone the repository and export your IP private as a variable; Eg:

export IP=$(ipconfig getifaddr en0)

Run the Docker Compose:

docker-compose up

Visit the apache nifi web site in http://localhost:8080

Upload nifi-templates/nifi-covid-kafka.xml in the section operate in the bottom on the page, once the template was uploaded you should drag the template in the toolbar on the top on the page and select the template uploaded.

Start the project and check if the PublishKafka procesor has received messages.

Checking

You can check the logs on the consumer and see that the consumer only show the messages with countries that have more than 1000 cases of COVID-19 confirmed.

docker-compose logs -f consumer

Explication