Class CreateTopicsResult
Admin.createTopics(Collection)
.
The API of this class is evolving, see Admin
for details.-
Nested Class Summary
-
Constructor Summary
ModifierConstructorDescriptionprotected
-
Method Summary
Modifier and TypeMethodDescriptionall()
Return a future which succeeds if all the topic creations succeed.Returns a future that provides topic configs for the topic when the request completes.numPartitions
(String topic) Returns a future that provides number of partitions in the topic when the request completes.replicationFactor
(String topic) Returns a future that provides replication factor for the topic when the request completes.Returns a future that provides topic ID for the topic when the request completes.values()
Return a map from topic names to futures, which can be used to check the status of individual topic creations.
-
Constructor Details
-
CreateTopicsResult
protected CreateTopicsResult(Map<String, KafkaFuture<CreateTopicsResult.TopicMetadataAndConfig>> futures)
-
-
Method Details
-
values
Return a map from topic names to futures, which can be used to check the status of individual topic creations. -
all
Return a future which succeeds if all the topic creations succeed. -
config
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
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
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
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.
-