@InterfaceStability.Evolving public class CreateTopicsResult extends Object
Admin.createTopics(Collection)
.
The API of this class is evolving, see Admin
for details.Modifier and Type | Class and Description |
---|---|
static class |
CreateTopicsResult.TopicMetadataAndConfig |
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.
|
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.
|
public Map<String,KafkaFuture<Void>> values()
public KafkaFuture<Void> all()
public KafkaFuture<Config> config(String topic)
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.
public KafkaFuture<Uuid> topicId(String topic)
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.
public KafkaFuture<Integer> numPartitions(String topic)
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.
public KafkaFuture<Integer> replicationFactor(String topic)
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.