Interface IRDKafkaAdminConnection

Readonly origin

createPartitions

• createPartitions(topic, desiredPartitions, timeout?): Promise<void>

• Parameters

  • topic: string
  • desiredPartitions: number
  • Optional timeout: number

  Returns Promise<void>

createTopic

• createTopic(topic, timeout?): Promise<void>

• Parameters

  • topic: NewTopic
  • Optional timeout: number

  Returns Promise<void>

deleteTopic

• deleteTopic(topic, timeout?): Promise<void>

• Parameters

  • topic: string
  • Optional timeout: number

  Returns Promise<void>