You may also be interested to try out the new Confluent JMS client for Kafka. It implements the JMS 1.1. API along with all the JMS metadata fields and access methods. It does this by putting/getting the JMS metadata into the body of an underlying Kafka message which is defined with a special JMS AVRO schema that includes both the JMS metadata as well as the JMS message body (which can be any of the JMS message types).
-hans > On Mar 14, 2017, at 9:26 AM, Robert Quinlivan <rquinli...@signal.co> wrote: > > Did you look at the ConsumerRecord > <https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html> > class? > > On Tue, Mar 14, 2017 at 11:09 AM, Syed Mudassir Ahmed < > smudas...@snaplogic.com> wrote: > >> Can anyone help? >> >> ---------- Forwarded message ---------- >> From: "Syed Mudassir Ahmed" <smudas...@snaplogic.com> >> Date: Mar 14, 2017 12:28 PM >> Subject: Question on Metadata >> To: <users@kafka.apache.org> >> Cc: >> >> Hi guys, >> When we consume a JMS message, we get a Message object that has methods >> to fetch implicit metadata provided by JMS server. >> http://docs.oracle.com/javaee/6/api/javax/jms/Message.html. There are >> methods to fetch that implicit metadata such as Expiration, Correlation ID, >> etc. >> >> Is there a way to fetch any such implicit metadata while consuming a >> kafka message? Any pointers to do that would be greatly appreciated. >> >> Thanks in advance. >> >> -- >> Thanks, >> Syed. >> > > > > -- > Robert Quinlivan > Software Engineer, Signal
