@ Then ( "^The number of partitions in topic '(.+?)' should be '(.+?)''?$" ) public void checkNumberOfPartitions ( String topic_name , int numOfPartitions ) throws Exception { Assertions . assertThat ( commonspec . getKafkaUtils ( ) . getPartitions ( topic_name ) ) . isEqualTo ( numOfPartitions ) ; }
Check that the number of partitions is like expected .