org.apache.storm.kafka

Class PartitionManager.OffsetData

java.lang.Object

org.apache.storm.kafka.PartitionManager.OffsetData

Enclosing class:

PartitionManager

public static class PartitionManager.OffsetData
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
long	latestCompletedOffset
long	latestEmittedOffset

Constructor Summary

Constructors

Constructor and Description
OffsetData(long latestEmittedOffset, long latestCompletedOffset)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

latestEmittedOffset

public long latestEmittedOffset

latestCompletedOffset

public long latestCompletedOffset

Constructor Detail

OffsetData

public OffsetData(long latestEmittedOffset,
                  long latestCompletedOffset)