Package com.infinyon.fluvio

Class PartitionConsumer

java.lang.Object

com.infinyon.fluvio.PartitionConsumer

public final class PartitionConsumer
extends Object

Create streams to read records from specific Fluvio topics and partitions.

Method Summary

Modifier and Type	Method	Description
void	delete()
protected void	finalize()
final PartitionConsumerStream	stream(Offset offset)	Create a stream to read records beginning at the given Offset.

Methods inherited from class java.lang.Object

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

Method Details

stream

public final PartitionConsumerStream stream(Offset offset)
                                     throws Exception

Create a stream to read records beginning at the given Offset.

Throws:

Exception

delete

public void delete()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable