com.github.panhongan.util.kafka

类 KafkaUtil

java.lang.Object

com.github.panhongan.util.kafka.KafkaUtil

public class KafkaUtil
extends Object

构造器概要

构造器

构造器和说明
KafkaUtil()

方法概要

方法

限定符和类型	方法和说明
static void	closeProducer(org.apache.kafka.clients.producer.Producer<String,String> producer)
static void	closeSimpleConsumer(kafka.javaapi.consumer.SimpleConsumer consumer)
static kafka.consumer.ConsumerConfig	createConsumerConfig(Config config)
static org.apache.kafka.clients.producer.Producer<String,String>	createProducer(Config producer_config)
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 boolean	isKafkaClusterAlive(String zk_list)
static void	sendAsync(org.apache.kafka.clients.producer.Producer<String,String> producer, String topic, String message, org.apache.kafka.clients.producer.Callback callback)
static boolean	sendSync(org.apache.kafka.clients.producer.Producer<String,String> producer, String topic, String message)

从类继承的方法 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 org.apache.kafka.clients.producer.Producer<String,String> createProducer(Config producer_config)

closeProducer

public static void closeProducer(org.apache.kafka.clients.producer.Producer<String,String> producer)

sendSync

public static boolean sendSync(org.apache.kafka.clients.producer.Producer<String,String> producer,
               String topic,
               String message)

sendAsync

public static void sendAsync(org.apache.kafka.clients.producer.Producer<String,String> producer,
             String topic,
             String message,
             org.apache.kafka.clients.producer.Callback callback)

createConsumerConfig

public static kafka.consumer.ConsumerConfig createConsumerConfig(Config config)

getConsumerGroupOwnerZKNode

public static String getConsumerGroupOwnerZKNode(String groupid,
                                 String topic)

getConsumerGroupOffsetZKNode

public static String getConsumerGroupOffsetZKNode(String groupid,
                                  String topic)

isKafkaClusterAlive

public static boolean isKafkaClusterAlive(String zk_list)