storm.kafka
Class KafkaSpout.MessageAndRealOffset
java.lang.Object
storm.kafka.KafkaSpout.MessageAndRealOffset
- Enclosing class:
- KafkaSpout
public static class KafkaSpout.MessageAndRealOffset
- extends Object
Field Summary |
kafka.message.Message |
msg
|
long |
offset
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
msg
public kafka.message.Message msg
offset
public long offset
KafkaSpout.MessageAndRealOffset
public KafkaSpout.MessageAndRealOffset(kafka.message.Message msg,
long offset)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.