private void sendMessage(ConsumerRecord<String,String> record){
  try {
    bus.send(busAddress,KafkaEvent.createEventForBus(record));
  }
 catch (  Exception ex) {
    String error=String.format("Error sending messages on event bus - record: %s",record.toString());
    logger.error(error,ex);
    bus.send(ConfigConstants.CONSUMER_ERROR_TOPIC,getErrorString(error,ex.getMessage()));
  }
}

private void sendMessage ( ConsumerRecord < String , String > record ) { try { bus . send ( busAddress , KafkaEvent . createEventForBus ( record ) ) ; } catch ( Exception ex ) { String error = String . format ( "Error sending messages on event bus - record: %s" , record . toString ( ) ) ; logger . error ( error , ex ) ; bus . send ( ConfigConstants . CONSUMER_ERROR_TOPIC , getErrorString ( error , ex . getMessage ( ) ) ) ; } }
send the inbound message to the event bus consumer .
