Uses of Class
io.vertx.kafka.admin.TopicDescription
-
Packages that use TopicDescription Package Description io.vertx.kafka.admin io.vertx.reactivex.kafka.admin io.vertx.rxjava3.kafka.admin -
-
Uses of TopicDescription in io.vertx.kafka.admin
Methods in io.vertx.kafka.admin that return TopicDescription Modifier and Type Method Description TopicDescription
TopicDescription. setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Set the id of the consumer groupTopicDescription
TopicDescription. setInternal(boolean internal)
Set whether the topic is internal to Kafka.TopicDescription
TopicDescription. setName(String name)
Set the name of the topic.TopicDescription
TopicDescription. setPartitions(List<TopicPartitionInfo> partitions)
Set A list of partitions where the index represents the partition id and the element contains leadership and replica information for that partition.TopicDescription
TopicDescription. setTopicId(org.apache.kafka.common.Uuid topicId)
Set the id of the topic.Methods in io.vertx.kafka.admin that return types with arguments of type TopicDescription Modifier and Type Method Description Future<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.Future<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames, DescribeTopicsOptions options)
LikeKafkaAdminClient.describeTopics(List)
but allows for customised otions -
Uses of TopicDescription in io.vertx.reactivex.kafka.admin
Methods in io.vertx.reactivex.kafka.admin that return types with arguments of type TopicDescription Modifier and Type Method Description Future<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.Future<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames, DescribeTopicsOptions options)
LikeKafkaAdminClient.describeTopics(java.util.List<java.lang.String>)
but allows for customised otionsSingle<Map<String,TopicDescription>>
KafkaAdminClient. rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.Single<Map<String,TopicDescription>>
KafkaAdminClient. rxDescribeTopics(List<String> topicNames, DescribeTopicsOptions options)
LikeKafkaAdminClient.describeTopics(java.util.List<java.lang.String>)
but allows for customised otions -
Uses of TopicDescription in io.vertx.rxjava3.kafka.admin
Methods in io.vertx.rxjava3.kafka.admin that return types with arguments of type TopicDescription Modifier and Type Method Description Single<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.Single<Map<String,TopicDescription>>
KafkaAdminClient. describeTopics(List<String> topicNames, DescribeTopicsOptions options)
LikeKafkaAdminClient.describeTopics(java.util.List<java.lang.String>)
but allows for customised otionsSingle<Map<String,TopicDescription>>
KafkaAdminClient. rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.Single<Map<String,TopicDescription>>
KafkaAdminClient. rxDescribeTopics(List<String> topicNames, DescribeTopicsOptions options)
LikeKafkaAdminClient.describeTopics(java.util.List<java.lang.String>)
but allows for customised otions
-