Code snippet to create kafka topics

create_kafka_topics.py

Topics = ["test1","test2"]
class createTopics:
    def __init__(self):
        self.a = AdminClient({'bootstrap.servers': 'localhost:9092',
                              'debug':'broker,admin,protocol',
                              'compression.type':'none',
                              'group.id':'mygroup'})
        new_topics = [NewTopic(topic, num_partitions=1, replication_factor=1)
            for topic in Topics]
        self.a.create_topics(new_topics)

def main():
    s = createTopics()