com.github.hackerwin7.jlib.utils.drivers.kafka.consumer

Class KafkaHighConsumer

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.kafka.consumer.KafkaHighConsumer

public class KafkaHighConsumer
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/08 Time: 4:14 PM Desc: kafka high level consumer client

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	KafkaHighConsumer.ConsumerTh consumer thread running consume

Field Summary

Fields

Modifier and Type	Field and Description
static int	QUEUE_SIZE
static long	SLEEPING_INTERVAL
static int	THREAD_COUNT

Constructor Summary

Constructors

Constructor and Description
KafkaHighConsumer(KafkaConf conf) constructor with kafka conf

Method Summary

Modifier and Type	Method and Description
KafkaMsg	consume() consume a msg
List<KafkaMsg>	consume(int num, long timeout) batch consume kafka
void	start() start the consumer client, start the thread pool to consume topic
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_SIZE

public static final int QUEUE_SIZE

See Also:

Constant Field Values

SLEEPING_INTERVAL

public static final long SLEEPING_INTERVAL

See Also:

Constant Field Values

THREAD_COUNT

public static final int THREAD_COUNT

See Also:

Constant Field Values

Constructor Detail

KafkaHighConsumer

public KafkaHighConsumer(KafkaConf conf)

constructor with kafka conf

Parameters:

conf -

Method Detail

start

public void start()

start the consumer client, start the thread pool to consume topic

stop

public void stop()

consume

public KafkaMsg consume()

consume a msg

Returns:

consume

public List<KafkaMsg> consume(int num,
                              long timeout)

batch consume kafka

Parameters:

num -

Returns: