vertx / io.vertx.kotlin.kafka.admin

Package io.vertx.kotlin.kafka.admin

Extensions for External Classes

io.vertx.kafka.admin.KafkaAdminClient

Functions

configEntryOf

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.

configOf

fun configOf(entries: Iterable<ConfigEntry>? = null): Config

A function providing a DSL for building io.vertx.kafka.admin.Config objects.

configSynonymOf

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.

consumerGroupDescriptionOf

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.

consumerGroupListingOf

fun consumerGroupListingOf(groupId: String? = null, simpleConsumerGroup: Boolean? = null): ConsumerGroupListing

A function providing a DSL for building io.vertx.kafka.admin.ConsumerGroupListing objects.

memberAssignmentOf

fun memberAssignmentOf(topicPartitions: Iterable<TopicPartition>? = null): MemberAssignment

A function providing a DSL for building io.vertx.kafka.admin.MemberAssignment objects.

memberDescriptionOf

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.

newTopicOf

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.

topicDescriptionOf

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.