pha.java.util.db

类 KafkaUtil

java.lang.Object

pha.java.util.db.KafkaUtil

public class KafkaUtil
extends Object

构造器概要

构造器

构造器和说明
KafkaUtil()

方法概要

方法

限定符和类型	方法和说明
static void	closeProducer(kafka.javaapi.producer.Producer<String,String> producer)
static kafka.javaapi.producer.Producer<String,String>	createProducer(String zkList, String kafkaList, boolean sync)
static kafka.javaapi.PartitionMetadata	findLeader(List<String> a_seedBrokers, int a_port, String a_topic, int a_partition)
static String	findNewLeader(List<String> a_seedBrokers, String a_oldLeader, String a_topic, int a_partition, int a_port)
static long	getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer, String topic, int partition, long whichTime, String clientName)
static int	sendBatch(kafka.javaapi.producer.Producer<String,String> producer, String topic, List<String> datas)

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

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

构造器详细资料

KafkaUtil

public KafkaUtil()

方法详细资料

getLastOffset

public static long getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
                 String topic,
                 int partition,
                 long whichTime,
                 String clientName)

findNewLeader

public static String findNewLeader(List<String> a_seedBrokers,
                   String a_oldLeader,
                   String a_topic,
                   int a_partition,
                   int a_port)
                            throws Exception

抛出:

Exception

findLeader

public static kafka.javaapi.PartitionMetadata findLeader(List<String> a_seedBrokers,
                                         int a_port,
                                         String a_topic,
                                         int a_partition)

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)