com.cloudera.oryx.kafka.util

Class KafkaUtils

java.lang.Object

com.cloudera.oryx.kafka.util.KafkaUtils

public final class KafkaUtils
extends Object

Kafka-related utility methods.

Method Summary

Modifier and Type	Method and Description
static void	deleteTopic(String zkServers, String topic)
static void	maybeCreateTopic(String zkServers, String topic, int partitions)
static void	maybeCreateTopic(String zkServers, String topic, int partitions, Properties topicProperties)
static void	setOffsets(String zkServers, String groupID, Map<Pair<String,Integer>,Long> offsets)
static boolean	topicExists(String zkServers, String topic)

Methods inherited from class java.lang.Object

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

Method Detail

maybeCreateTopic

public static void maybeCreateTopic(String zkServers,
                                    String topic,
                                    int partitions)

Parameters:

zkServers - Zookeeper server string: host1:port1[,host2:port2,...]

topic - topic to create (if not already existing)

partitions - number of topic partitions

maybeCreateTopic

public static void maybeCreateTopic(String zkServers,
                                    String topic,
                                    int partitions,
                                    Properties topicProperties)

Parameters:

zkServers - Zookeeper server string: host1:port1[,host2:port2,...]

topic - topic to create (if not already existing)

partitions - number of topic partitions

topicProperties - optional topic config properties

topicExists

public static boolean topicExists(String zkServers,
                                  String topic)

Parameters:

zkServers - Zookeeper server string: host1:port1[,host2:port2,...]

topic - topic to check for existence

Returns:

true if and only if the given topic exists

deleteTopic

public static void deleteTopic(String zkServers,
                               String topic)

Parameters:

zkServers - Zookeeper server string: host1:port1[,host2:port2,...]

topic - topic to delete, if it exists

setOffsets

public static void setOffsets(String zkServers,
                              String groupID,
                              Map<Pair<String,Integer>,Long> offsets)

Parameters:

zkServers - Zookeeper server string: host1:port1[,host2:port2,...]

groupID - consumer group to update

offsets - mapping of (topic and) partition to offset to push to Zookeeper