question: 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 ( ) ) ) ; } }
target:  Send the inbound message to the event bus consumer.