Skip to content

Message

Jump to bottom
ppatierno edited this page May 2, 2016 · 6 revisions

The AMQP protocol has a well defined data type system and metadata for describing content other than an opaque body, which can be encoded using the same AMQP data type system or handled as raw data bytes. Apache Kafka doesn't have such rich features on transferring messages which are handled as raw bytes.

In order to translate AMQP messages between AMQP client and Apache Kafka, a MessageConverter interface is defined with following two methods :

  • toKafkaRecord : handles the conversion between an AMQP message to Kafka record;
  • toAmqpMessage : translated a Kafka record to an AMQP messages;

The message converter is pluggable through the message.convert property inside the bridge configuration file (bridge.properties).

The bridge provides a DefaultMessageConverter (as default) and a pluggable JsonMessageConverter.

DefaultMessageConverter

TBD

JsonMessageConverter

TBD

Clone this wiki locally