com.github.panhongan.util.kafka

类 KafkaUtil

java.lang.Object

com.github.panhongan.util.kafka.KafkaUtil

public class KafkaUtil
extends Object

构造器概要

构造器

构造器和说明
KafkaUtil()

方法概要

方法

限定符和类型	方法和说明
static void	closeProducer(kafka.javaapi.producer.Producer<String,String> producer)
static void	closeSimpleConsumer(kafka.javaapi.consumer.SimpleConsumer consumer)
static kafka.consumer.ConsumerConfig	createConsumerConfig(String zk_list, String group_id, boolean from_beginning)
static kafka.javaapi.producer.Producer<String,String>	createProducer(String zkList, String kafkaList, boolean sync)
static kafka.javaapi.TopicMetadata	findTopicMetadata(List<String> broker_hosts, int port, String topic)
static List<kafka.javaapi.PartitionMetadata>	findTopicPartitionMetadata(List<String> broker_hosts, int port, String topic)
static kafka.javaapi.PartitionMetadata	findTopicPartitionMetadata(List<String> broker_hosts, int port, String topic, int partition)
static String	getConsumerGroupOffsetZKNode(String groupid, String topic)
static String	getConsumerGroupOwnerZKNode(String groupid, String topic)
static long	getLastestWriteOffset(String broker_leader, int port, String topic, int partition)
static Map<Integer,Long>	getLastestWriteOffset(String broker_list, String topic)
static int	sendBatch(kafka.javaapi.producer.Producer<String,String> producer, String topic, List<String> datas)
static int	sendData(kafka.javaapi.producer.Producer<String,String> producer, String topic, String data)

从类继承的方法 java.lang.Object

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

构造器详细资料

KafkaUtil

public KafkaUtil()

方法详细资料

getLastestWriteOffset

public static Map<Integer,Long> getLastestWriteOffset(String broker_list,
                                      String topic)

getLastestWriteOffset

public static long getLastestWriteOffset(String broker_leader,
                         int port,
                         String topic,
                         int partition)

findTopicMetadata

public static kafka.javaapi.TopicMetadata findTopicMetadata(List<String> broker_hosts,
                                            int port,
                                            String topic)

findTopicPartitionMetadata

public static List<kafka.javaapi.PartitionMetadata> findTopicPartitionMetadata(List<String> broker_hosts,
                                                               int port,
                                                               String topic)

findTopicPartitionMetadata

public static kafka.javaapi.PartitionMetadata findTopicPartitionMetadata(List<String> broker_hosts,
                                                         int port,
                                                         String topic,
                                                         int partition)

closeSimpleConsumer

public static void closeSimpleConsumer(kafka.javaapi.consumer.SimpleConsumer consumer)

createProducer

public static kafka.javaapi.producer.Producer<String,String> createProducer(String zkList,
                                                            String kafkaList,
                                                            boolean sync)

closeProducer

public static void closeProducer(kafka.javaapi.producer.Producer<String,String> producer)

sendBatch

public static int sendBatch(kafka.javaapi.producer.Producer<String,String> producer,
            String topic,
            List<String> datas)

sendData

public static int sendData(kafka.javaapi.producer.Producer<String,String> producer,
           String topic,
           String data)

createConsumerConfig

public static kafka.consumer.ConsumerConfig createConsumerConfig(String zk_list,
                                                 String group_id,
                                                 boolean from_beginning)

getConsumerGroupOwnerZKNode

public static String getConsumerGroupOwnerZKNode(String groupid,
                                 String topic)

getConsumerGroupOffsetZKNode

public static String getConsumerGroupOffsetZKNode(String groupid,
                                  String topic)