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 'Data owner' role and 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 project = hopsworks.login() 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.