@ 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 ) ; }
Modify partitions in a Kafka topic .