code: @When("^I send a message '(.+?)' to the kafka topic named '(.+?)'")
      public void sendAMessage(String message, String topic_name) throws Exception {
          commonspec.getKafkaUtils().sendMessage(message, topic_name);
      }
docs: Sending a message in a Kafka topic.
  
  @param topic_name topic name
  @param message    string that you send to topic