@InterfaceStability.Evolving public class DescribeTopicsResult extends Object
Admin.describeTopics(Collection)
call.
The API of this class is evolving, see Admin
for details.Modifier | Constructor and Description |
---|---|
protected |
DescribeTopicsResult(Map<String,KafkaFuture<TopicDescription>> futures) |
Modifier and Type | Method and Description |
---|---|
KafkaFuture<Map<String,TopicDescription>> |
all()
Return a future which succeeds only if all the topic descriptions succeed.
|
Map<String,KafkaFuture<TopicDescription>> |
values()
Return a map from topic names to futures which can be used to check the status of
individual topics.
|
protected DescribeTopicsResult(Map<String,KafkaFuture<TopicDescription>> futures)
public Map<String,KafkaFuture<TopicDescription>> values()
public KafkaFuture<Map<String,TopicDescription>> all()