Kafka Python Create a Kafka Topic

Creating a kafka Topic Using Kafka Python Modules


1. Import python module

import kafka

2. Make Connection

admin_client = KafkaAdminClient(bootstrap_servers=[broker_host])

3. Get list of toipcs

topic_list = []
topic_list.append(NewTopic(name=bucket_name,
num_partitions=num_part, replication_factor=repl_factor))

4. Create Topics
admin_client.create_topics(new_topics=topic_list,validate_only=False)

5. Closing connection
admin_client.close()