code: @When("^I increase '(.+?)' partitions in a Kafka topic named '(.+?)'")
      public void modifyPartitions(int numPartitions, String topic_name) throws Exception {
          commonspec.getKafkaUtils().modifyTopicPartitioning(topic_name, numPartitions);
      }
docs: Modify partitions in a Kafka topic.
  
  @param topic_name    topic name
  @param numPartitions number of partitions