Package org.apache.kafka.clients.admin

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CreateTopicsResult.TopicMetadataAndConfig

Method Summary

Modifier and Type	Method	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.
KafkaFuture<Uuid>	topicId(String topic)	Returns a future that provides topic ID 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

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

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. Note that the values for the type and documentation fields will be null.

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.