@Override public void SendCanaryToTopicPartition(String topicName,String partitionId){
  m_producer.send(createCanaryMessage(topicName,partitionId));
}

@ Override public void SendCanaryToTopicPartition ( String topicName , String partitionId ) { m_producer . send ( createCanaryMessage ( topicName , partitionId ) ) ; }
sends the message to specified topic and partition
