com.cloudera.oryx.kafka.util

Class ConsumeDataIterator<K,V>

java.lang.Object

com.google.common.collect.UnmodifiableIterator<T>

com.google.common.collect.AbstractIterator<KeyMessage<K,V>>

com.cloudera.oryx.kafka.util.ConsumeDataIterator<K,V>

Type Parameters:

K - key type

V - value type

All Implemented Interfaces:

CloseableIterator<KeyMessage<K,V>>, Closeable, AutoCloseable, Iterator<KeyMessage<K,V>>

public final class ConsumeDataIterator<K,V>
extends com.google.common.collect.AbstractIterator<KeyMessage<K,V>>
implements CloseableIterator<KeyMessage<K,V>>

An iterator over records in a Kafka topic.

Constructor Summary

Constructors

Constructor and Description
ConsumeDataIterator(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)

Method Summary

Modifier and Type	Method and Description
void	close()
protected KeyMessage<K,V>	computeNext()

Methods inherited from class com.google.common.collect.AbstractIterator

endOfData, hasNext, next, peek

Methods inherited from class com.google.common.collect.UnmodifiableIterator

remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Constructor Detail

ConsumeDataIterator

public ConsumeDataIterator(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)

Method Detail

computeNext

protected KeyMessage<K,V> computeNext()

Specified by:

computeNext in class com.google.common.collect.AbstractIterator<KeyMessage<K,V>>

close

public void close()

Specified by:

close in interface CloseableIterator<KeyMessage<K,V>>

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable