public class KafkaUtils extends Object
| Modifier and Type | Field and Description |
|---|---|
static long |
SLEEPING_TIME |
static String |
ZK_IDS_PATH |
static String |
ZK_TOPICS_PATH |
| Constructor and Description |
|---|
KafkaUtils(String zkconnStr)
build zk client and load global broker id mapping
|
| 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) |
public static final String ZK_TOPICS_PATH
public static final String ZK_IDS_PATH
public static final long SLEEPING_TIME
public TopicInfo findTopicInfo(String topic) throws Exception
topic - Exceptionpublic static long getMinOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
String topic,
int partition)
throws Exception
ExceptionCopyright © 2016. All rights reserved.