Class CreateTopicsResult

java.lang.Object
org.apache.kafka.clients.admin.CreateTopicsResult

@Evolving public class CreateTopicsResult extends Object
The result of Admin.createTopics(Collection). The API of this class is evolving, see Admin for details.
  • Constructor Details

  • Method Details

    • values

      public Map<String,KafkaFuture<Void>> values()
      Return a map from topic names to futures, which can be used to check the status of individual topic creations.
    • all

      public KafkaFuture<Void> all()
      Return a future which succeeds if all the topic creations succeed.
    • config

      public KafkaFuture<Config> config(String topic)
      Returns a future that provides topic configs for the topic when the request completes.

      If broker version doesn't support replication factor in the response, throw UnsupportedVersionException. If broker returned an error for topic configs, throw appropriate exception. For example, TopicAuthorizationException is thrown if user does not have permission to describe topic configs.

    • topicId

      public KafkaFuture<Uuid> topicId(String topic)
      Returns a future that provides topic ID for the topic when the request completes.

      If broker version doesn't support replication factor in the response, throw UnsupportedVersionException. If broker returned an error for topic configs, throw appropriate exception. For example, TopicAuthorizationException is thrown if user does not have permission to describe topic configs.

    • numPartitions

      public KafkaFuture<Integer> numPartitions(String topic)
      Returns a future that provides number of partitions in the topic when the request completes.

      If broker version doesn't support replication factor in the response, throw UnsupportedVersionException. If broker returned an error for topic configs, throw appropriate exception. For example, TopicAuthorizationException is thrown if user does not have permission to describe topic configs.

    • replicationFactor

      public KafkaFuture<Integer> replicationFactor(String topic)
      Returns a future that provides replication factor for the topic when the request completes.

      If broker version doesn't support replication factor in the response, throw UnsupportedVersionException. If broker returned an error for topic configs, throw appropriate exception. For example, TopicAuthorizationException is thrown if user does not have permission to describe topic configs.