TopicAdmin

interface TopicAdmin

Describes and creates the topics of a broker: the port the runtime validates and creates a node's topics through at its start, as wow.kafka.ddl says. Neither call creates a topic as a side effect of asking about it.

  • partitions gives the partition count of each of topics that exists; one that does not is left out.

  • create creates each topic of topics with its partition count, the broker's replication and topic settings being the implementation's; a topic that exists already, such as one another node created at the same moment, is left as it is. It returns once the created topics can be described.

Functions

Link copied to clipboard
abstract suspend fun create(topics: Map<String, Int>)
Link copied to clipboard
abstract suspend fun partitions(topics: Set<String>): Map<String, Int>