Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class KafkaMessage

java.lang.Object
  extended by org.springframework.integration.kafka.core.KafkaMessage

public class KafkaMessage
extends java.lang.Object

Wrapper around a kafka message and its metadata.

Author:
Marius Bogoevici

Constructor Summary
KafkaMessage(kafka.message.Message message, KafkaMessageMetadata metadata)
           
 
Method Summary
 kafka.message.Message getMessage()
           
 KafkaMessageMetadata getMetadata()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

KafkaMessage

public KafkaMessage(kafka.message.Message message,
                    KafkaMessageMetadata metadata)
Method Detail

getMessage

public kafka.message.Message getMessage()

getMetadata

public KafkaMessageMetadata getMetadata()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

Spring Integration Kafka Support