Class CreateTopicsResult
- java.lang.Object
-
- org.apache.kafka.clients.admin.CreateTopicsResult
-
@Evolving public class CreateTopicsResult extends Object
The result ofAdmin.createTopics(Collection)
. The API of this class is evolving, seeAdmin
for details.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CreateTopicsResult.TopicMetadataAndConfig
-
Constructor Summary
Constructors Modifier Constructor Description protected
CreateTopicsResult(Map<String,KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>> futures)
-
Method Summary
All Methods Instance Methods Concrete Methods 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.
-
-
-
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.
-
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.
-
-