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) |
public static long getLastOffset(kafka.javaapi.consumer.SimpleConsumer consumer,
String topic,
int partition,
long whichTime,
String clientName)
public static String findNewLeader(List<String> a_seedBrokers, String a_oldLeader, String a_topic, int a_partition, int a_port) throws Exception
Exceptionpublic static kafka.javaapi.PartitionMetadata findLeader(List<String> a_seedBrokers, int a_port, String a_topic, int a_partition)
public static kafka.javaapi.producer.Producer<String,String> createProducer(String zkList, String kafkaList, boolean sync)
public static void closeProducer(kafka.javaapi.producer.Producer<String,String> producer)
Copyright © 2016. All rights reserved.