class Kafka::Client

def delete_topic(name, timeout: 30)

Returns:
  • (nil) -

Parameters:
  • timeout (Integer) -- a duration of time to wait for the topic to be
  • name (String) -- the name of the topic. 
def delete_topic(name, timeout: 30)
  @cluster.delete_topic(name, timeout: timeout)
end