Method: Kafka::Client#delete_topic

Defined in:
lib/kafka/client.rb

#delete_topic(name, timeout: 30) ⇒ nil

Delete a topic in the cluster.

Parameters:

  • name (String) —

    the name of the topic.

  • timeout (Integer) (defaults to: 30) —

    a duration of time to wait for the topic to be completely marked deleted.

Returns:

  • (nil) 


638
639
640
 
# File 'lib/kafka/client.rb', line 638

def delete_topic(name, timeout: 30)
  @cluster.delete_topic(name, timeout: timeout)
end