code: @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);
  
      }
docs: Check that the number of partitions is like expected.
  
  @param topic_name      Name of kafka topic
  @param numOfPartitions Number of partitions
  @throws Exception