public class TopicDescription extends Object
Constructor and Description |
---|
TopicDescription(String name,
boolean internal,
List<TopicPartitionInfo> partitions)
Create an instance with the specified parameters.
|
TopicDescription(String name,
boolean internal,
List<TopicPartitionInfo> partitions,
Set<AclOperation> authorizedOperations)
Create an instance with the specified parameters.
|
Modifier and Type | Method and Description |
---|---|
Set<AclOperation> |
authorizedOperations()
authorized operations for this topic, or null if this is not known.
|
boolean |
equals(Object o) |
int |
hashCode() |
boolean |
isInternal()
Whether the topic is internal to Kafka.
|
String |
name()
The name of the topic.
|
List<TopicPartitionInfo> |
partitions()
A list of partitions where the index represents the partition id and the element contains leadership and replica
information for that partition.
|
String |
toString() |
public TopicDescription(String name, boolean internal, List<TopicPartitionInfo> partitions)
name
- The topic nameinternal
- Whether the topic is internal to Kafkapartitions
- A list of partitions where the index represents the partition id and the element contains
leadership and replica information for that partition.public TopicDescription(String name, boolean internal, List<TopicPartitionInfo> partitions, Set<AclOperation> authorizedOperations)
name
- The topic nameinternal
- Whether the topic is internal to Kafkapartitions
- A list of partitions where the index represents the partition id and the element contains
leadership and replica information for that partition.authorizedOperations
- authorized operations for this topic, or null if this is not known.public String name()
public boolean isInternal()
public List<TopicPartitionInfo> partitions()
public Set<AclOperation> authorizedOperations()