Interface IRDKafkaAdminConnection

Readonly origin

createPartitions

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

• Parameters

  • topic: string

  • desiredPartitions: number

  • Optional timeout: number

    Optional

  Returns Promise<void>

createTopic

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

• Parameters

  • topic: NewTopic

  • Optional timeout: number

    Optional

  Returns Promise<void>

deleteTopic

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

• Parameters

  • topic: string

  • Optional timeout: number

    Optional

  Returns Promise<void>