Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class KafkaMessageMetadata

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

public class KafkaMessageMetadata
extends java.lang.Object

Metadata for a Kafka Message.

Author:
Marius Bogoevici

Constructor Summary
KafkaMessageMetadata(Partition partition, long offset, long nextOffset)
           
 
Method Summary
 long getNextOffset()
           
 long getOffset()
           
 Partition getPartition()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

KafkaMessageMetadata

public KafkaMessageMetadata(Partition partition,
                            long offset,
                            long nextOffset)
Method Detail

getPartition

public Partition getPartition()

getOffset

public long getOffset()

getNextOffset

public long getNextOffset()

toString

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

Spring Integration Kafka Support