How To Create A Kafka Topic#
A Topic is a queue to which records are stored and published. Producer applications write data to topics and consumer applications read from topics.
This guide requires that you have previously created a Kafka Schema to be used for the topic.
In this guide, you will learn how to create a Kafka Topic.
Step 1: Get the Kafka API#
import hopsworks connection = hopsworks.connection() project = connection.get_project() kafka_api = project.get_kafka_api()
Step 2: Define the schema#
TOPIC_NAME="topic_example" SCHEMA_NAME="schema_example" my_topic = kafka_api.create_topic(TOPIC_NAME, SCHEMA_NAME, 1, replicas=1, partitions=1)
In this guide you learned how to create a Kafka Topic.