org.cg.eventbus.consumer.bytestream

Class GenericFetcher

java.lang.Object

org.cg.eventbus.consumer.bytestream.GenericFetcher

public class GenericFetcher
extends Object

Generic Kafka Consumer

Author:

liang.li

Constructor Summary

Constructors

Constructor and Description
GenericFetcher(org.apache.commons.configuration.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commit()
boolean	hasNext()
Message	read()

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericFetcher

public GenericFetcher(org.apache.commons.configuration.Configuration conf)

Method Detail

hasNext

public boolean hasNext()

read

public Message read()

commit

public void commit()

close

public void close()