fun configEntryOf(default: Boolean? = null, name: String? = null, readOnly: Boolean? = null, sensitive: Boolean? = null, source: ConfigSource? = null, synonyms: Iterable<ConfigSynonym>? = null, value: String? = null): ConfigEntry
A function providing a DSL for building io.vertx.kafka.admin.ConfigEntry objects. |
|
fun configOf(entries: Iterable<ConfigEntry>? = null): Config
A function providing a DSL for building io.vertx.kafka.admin.Config objects. |
|
fun configSynonymOf(name: String? = null, source: ConfigSource? = null, value: String? = null): ConfigSynonym
A function providing a DSL for building io.vertx.kafka.admin.ConfigSynonym objects. |
|
fun consumerGroupDescriptionOf(coordinator: Node? = null, groupId: String? = null, members: Iterable<MemberDescription>? = null, partitionAssignor: String? = null, simpleConsumerGroup: Boolean? = null, state: ConsumerGroupState? = null): ConsumerGroupDescription
A function providing a DSL for building io.vertx.kafka.admin.ConsumerGroupDescription objects. |
|
fun consumerGroupListingOf(groupId: String? = null, simpleConsumerGroup: Boolean? = null): ConsumerGroupListing
A function providing a DSL for building io.vertx.kafka.admin.ConsumerGroupListing objects. |
|
fun memberAssignmentOf(topicPartitions: Iterable<TopicPartition>? = null): MemberAssignment
A function providing a DSL for building io.vertx.kafka.admin.MemberAssignment objects. |
|
fun memberDescriptionOf(assignment: MemberAssignment? = null, clientId: String? = null, consumerId: String? = null, host: String? = null): MemberDescription
A function providing a DSL for building io.vertx.kafka.admin.MemberDescription objects. |
|
fun newTopicOf(config: Map<String, String>? = null, name: String? = null, numPartitions: Int? = null, replicationFactor: Short? = null): NewTopic
A function providing a DSL for building io.vertx.kafka.admin.NewTopic objects. |
|
fun topicDescriptionOf(internal: Boolean? = null, name: String? = null, partitions: Iterable<TopicPartitionInfo>? = null): TopicDescription
A function providing a DSL for building io.vertx.kafka.admin.TopicDescription objects. |