code: def create_topics(self, new_topics, **kwargs):
          
  
          f, futmap = AdminClient._make_futures([x.topic for x in new_topics],
                                                None,
                                                AdminClient._make_topics_result)
  
          super(AdminClient, self).create_topics(new_topics, f, **kwargs)
  
          return futmap
docs: Create new topics in cluster.
  
          The future result() value is None.
  
          :param list(NewTopic) new_topics: New topics to be created.
          :param float operation_timeout: Set broker's operation timeout in seconds,
                    controlling how long the CreateTopics request will block
                    on the broker waiting for the topic creation to propagate
                    in the cluster. A value of 0 returns immediately. Default: 0
          :param float request_timeout: Set the overall request timeout in seconds,
                    including broker lookup, request transmission, operation time
                    on broker, and response. Default: `socket.timeout.ms*1000.0`
          :param bool validate_only: Tell broker to only validate the request,
                    without creating the topic. Default: False
  
          :returns: a dict of futures for each topic, keyed by the topic name.
          :rtype: dict(<topic_name, future>)
  
          :raises KafkaException: Operation failed locally or on broker.
          :raises TypeException: Invalid input.
          :raises ValueException: Invalid input.