Difficulty: Beginner
Estimated Time: 15 minutes

DataStax Apache Kafka™ Connector is installed in the Kafka Connect framework, and synchronizes records from a Kafka topic with table rows in Apache Cassandra, DataStax Enterprise and DataStax Astra.

In this scenario, we will learn how to:

  • Create a Kafka topic
  • Configure and start a Kafka Connect Worker
  • Download and configure the DataStax Kafka Connector
  • Push data from the topic in Kafka to a Cassandra instance

Good job! You have just learned how to push data to Cassandra from Kafka with the DataStax Kafka connector.

DataStax Apache Kafka™ Connector Quickstart

Step 1 of 6

Create Cassandra Schema

Wait for Cassandra to finish starting up, then we will start creating the table for the user data that will be coming into Cassandra.

apache-cassandra-4.0-beta1/bin/cqlsh --file 'users.cql'

If you take a look at the users.cql file, you'll see that this file creates a simple demo keyspace and users table.

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

CREATE TABLE demo.users (
  lastname text PRIMARY KEY,
  firstname text,
  email text
);

Great work! You have just created a keyspace and table in Cassandra.