org.apache.kafka.clients.admin

Class CreateTopicsResult

java.lang.Object

org.apache.kafka.clients.admin.CreateTopicsResult

@InterfaceStability.Evolving
public class CreateTopicsResult
extends Object

The result of Admin.createTopics(Collection). The API of this class is evolving, see Admin for details.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CreateTopicsResult.TopicMetadataAndConfig

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CreateTopicsResult(Map<String,KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>> futures)

Method Summary

Modifier and Type	Method and Description
KafkaFuture<Void>	all() Return a future which succeeds if all the topic creations succeed.
KafkaFuture<Config>	config(String topic) Returns a future that provides topic configs for the topic when the request completes.
KafkaFuture<Integer>	numPartitions(String topic) Returns a future that provides number of partitions in the topic when the request completes.
KafkaFuture<Integer>	replicationFactor(String topic) Returns a future that provides replication factor for the topic when the request completes.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateTopicsResult

protected CreateTopicsResult(Map<String,KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>> futures)

Method Detail

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.

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.