code: def example_create_topics(a, topics):
      
  
      new_topics = [NewTopic(topic, num_partitions=3, replication_factor=1) for topic in topics]
      # Call create_topics to asynchronously create topics, a dict
      # of <topic,future> is returned.
      fs = a.create_topics(new_topics)
  
      # Wait for operation to finish.
      # Timeouts are preferably controlled by passing request_timeout=15.0
      # to the create_topics() call.
      # All futures will finish at the same time.
      for topic, f in fs.items():
          try:
              f.result()  # The result itself is None
              print("Topic {} created".format(topic))
          except Exception as e:
              print("Failed to create topic {}: {}".format(topic, e))
docs: Create topics