com.github.hackerwin7.jlib.utils.drivers.kafka.producer

Class KafkaProducer

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.kafka.producer.KafkaProducer

public class KafkaProducer
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/08 Time: 11:45 AM Desc: kafka producer client

Constructor Summary

Constructors

Constructor and Description
KafkaProducer(KafkaConf conf) constructor kafka producer client by kafka conf

Method Summary

Modifier and Type	Method and Description
void	close() close producer client
void	send(kafka.producer.KeyedMessage<String,byte[]> msg)
void	send(List<kafka.producer.KeyedMessage<String,byte[]>> msgs)
void	sendKafkaMsg(KafkaMsg msg) sendKafkaMsg single
void	sendKafkaMsg(List<KafkaMsg> msgs) sendKafkaMsg batch
static kafka.producer.KeyedMessage<String,byte[]>	toKeyedMessage(KafkaMsg msg) convert to keyedmessage
static List<kafka.producer.KeyedMessage<String,byte[]>>	toKeyedMessage(List<KafkaMsg> msgs) convert to batch keyedmessages

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaProducer

public KafkaProducer(KafkaConf conf)

constructor kafka producer client by kafka conf

Parameters:

conf -

Method Detail

close

public void close()

close producer client

sendKafkaMsg

public void sendKafkaMsg(KafkaMsg msg)

sendKafkaMsg single

Parameters:

msg -

sendKafkaMsg

public void sendKafkaMsg(List<KafkaMsg> msgs)

sendKafkaMsg batch

Parameters:

msgs -

send

public void send(kafka.producer.KeyedMessage<String,byte[]> msg)

send

public void send(List<kafka.producer.KeyedMessage<String,byte[]>> msgs)

toKeyedMessage

public static kafka.producer.KeyedMessage<String,byte[]> toKeyedMessage(KafkaMsg msg)

convert to keyedmessage

Parameters:

msg -

Returns:

toKeyedMessage

public static List<kafka.producer.KeyedMessage<String,byte[]>> toKeyedMessage(List<KafkaMsg> msgs)

convert to batch keyedmessages

Parameters:

msgs -

Returns: