Apache Cassandra and Apache Nifi

Learn how to connect Apache Cassandra and Apache Nifi! We will show you how you can quickly connect Apache Cassandra and Apache Nifi and confirm you are able to use Nifi and Cassandra together.

Prerequisites

• Docker
• Nifi 1.14.0

1. Setup Dockerized Apache Cassandra

1.1 - Start Apache Cassandra Container and Mount Directory

docker run --name cassandra -p 9042:9042 -d cassandra:latest

1.2 - Run cqlsh

docker exec -it cassandra cqlsh

1.3 - Copy and paste below items into the CQLSH terminal

CREATE KEYSPACE demo WITH REPLICATION={'class': 'SimpleStrategy', 'replication_factor': 1};

CREATE TABLE demo.previous_employees_by_job_title (
    job_title text,
    employee_id uuid,
    employee_name text,
    first_day timestamp,
    last_day timestamp,
    PRIMARY KEY (job_title, employee_id)
) WITH CLUSTERING ORDER BY (employee_id ASC);

insert into previous_employees_by_job_title (job_title, employee_id, employee_name, first_day, last_day)
values('Biologist', e48fd2c9-3abb-4592-a7d6-ccccf06e991e, 'Fiona Lane', '2009-02-26 20:47:18Z', '2005-10-13 20:01:22Z') ;

2. Start Nifi

2.1 - Navigate to Apache Nifi directory and start in background mode

./bin/nifi.sh start

2.2 - Log into Apache Nifi

Navigate to https://localhost:8443/nifi/login

If this is your first time logging into local Apache Nifi, you will need to find the autogenerated credentials. You can do so by running the below command within the Apache Nifi directory and then searching for Username and Password:

cat logs/nifi-app_<date>.log

3. Watch the rest of the walkthrough on our YouTube Channel!

Resources

• Accompanying Blog
• Accompanying YouTube
• https://nifi.apache.org/docs.html
• https://youtu.be/PO_4yarPBrw