class Kafka::Client

def create_partitions_for(name, num_partitions: 1, timeout: 30)

Returns:
  • (nil) -

Parameters:
  • timeout (Integer) -- a duration of time to wait for the new
  • num_partitions (Integer) -- the number of desired partitions for
  • name (String) -- the name of the topic. 
def create_partitions_for(name, num_partitions: 1, timeout: 30)
  @cluster.create_partitions_for(name, num_partitions: num_partitions, timeout: timeout)
end