storm.kafka

Class KafkaSpout.MessageAndRealOffset

java.lang.Object

storm.kafka.KafkaSpout.MessageAndRealOffset

Enclosing class:

KafkaSpout

public static class KafkaSpout.MessageAndRealOffset
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
kafka.message.Message	msg
long	offset

Constructor Summary

Constructors

Constructor and Description
MessageAndRealOffset(kafka.message.Message msg, long offset)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

msg

public kafka.message.Message msg

offset

public long offset

Constructor Detail

MessageAndRealOffset

public MessageAndRealOffset(kafka.message.Message msg,
                            long offset)