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

Class KafkaUtils

java.lang.Object

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

public class KafkaUtils
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/18 Time: 11:19 AM Desc: obtain kafka information using zk, independent kafka utils

Field Summary

Fields

Modifier and Type	Field and Description
static long	SLEEPING_TIME
static String	ZK_IDS_PATH
static String	ZK_TOPICS_PATH

Constructor Summary

Constructors

Constructor and Description
KafkaUtils(String zkconnStr) build zk client and load global broker id mapping

Method Summary

Modifier and Type	Method and Description
TopicInfo	findTopicInfo(String topic) getOrigin topic information by using topic and zkconn
static long	getMaxOffset(kafka.javaapi.consumer.SimpleConsumer consumer, String topic, int partition)
static long	getMinOffset(kafka.javaapi.consumer.SimpleConsumer consumer, String topic, int partition)

Methods inherited from class java.lang.Object

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

Field Detail

ZK_TOPICS_PATH

public static final String ZK_TOPICS_PATH

See Also:

Constant Field Values

ZK_IDS_PATH

public static final String ZK_IDS_PATH

See Also:

Constant Field Values

SLEEPING_TIME

public static final long SLEEPING_TIME

See Also:

Constant Field Values

Constructor Detail

KafkaUtils

public KafkaUtils(String zkconnStr)
           throws Exception

build zk client and load global broker id mapping

Parameters:

zkconnStr -

Throws:

Exception

Method Detail

findTopicInfo

public TopicInfo findTopicInfo(String topic)
                        throws Exception

getOrigin topic information by using topic and zkconn

Parameters:

topic -

Returns:

topic info

Throws:

Exception

getMinOffset

public static long getMinOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
                                String topic,
                                int partition)
                         throws Exception

Throws:

Exception

getMaxOffset

public static long getMaxOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
                                String topic,
                                int partition)
                         throws Exception

Throws:

Exception