storm.kafka
Class KafkaSpout.MessageAndRealOffset

java.lang.Object
  extended by storm.kafka.KafkaSpout.MessageAndRealOffset
Enclosing class:
KafkaSpout

public static class KafkaSpout.MessageAndRealOffset
extends Object


Field Summary
 kafka.message.Message msg
           
 long offset
           
 
Constructor Summary
KafkaSpout.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

KafkaSpout.MessageAndRealOffset

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


Copyright © 2015 The Apache Software Foundation. All Rights Reserved.