Package com.infinyon.fluvio

Class PartitionConsumerStream

java.lang.Object

com.infinyon.fluvio.PartitionConsumerStream

public final class PartitionConsumerStream
extends Object

A stream that yields records from the origin topic and partition, starting at the given offset.

Method Summary

Modifier and Type	Method	Description
void	delete()
protected void	finalize()
final Record	next()

Methods inherited from class java.lang.Object

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

Method Details

next

public final Record next()
                  throws Exception

Throws:

Exception

delete

public void delete()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable