def create_partitions_for(name, num_partitions: 1, timeout: 30)
      @cluster.create_partitions_for(name, num_partitions: num_partitions, timeout: timeout)
    end
def create_partitions_for(name, num_partitions: 1, timeout: 30)
      @cluster.create_partitions_for(name, num_partitions: num_partitions, timeout: timeout)
    end
Create partitions for a topic.

 @param name [String] the name of the topic.
 @param num_partitions [Integer] the number of desired partitions for
 the topic
 @param timeout [Integer] a duration of time to wait for the new
 partitions to be added.
 @return [nil]