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

Class KafkaSimpleConsumer.ConsumeThread

java.lang.Object

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

All Implemented Interfaces:

Runnable

Enclosing class:

KafkaSimpleConsumer

public class KafkaSimpleConsumer.ConsumeThread
extends Object
implements Runnable

start the thread to run the consumer

Constructor Summary

Constructors

Constructor and Description
ConsumeThread(Map<String,Integer> brokers, int partition, long beginOffset, long endOffset) constructor with broker and partition, offset

Method Summary

Modifier and Type	Method and Description
void	run() run consumer to consume the kafka message

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumeThread

public ConsumeThread(Map<String,Integer> brokers,
                     int partition,
                     long beginOffset,
                     long endOffset)

constructor with broker and partition, offset

Parameters:

brokers -

partition -

beginOffset -

endOffset -

Method Detail

run

public void run()

run consumer to consume the kafka message

Specified by:

run in interface Runnable