程序包 xin.manong.weapon.base.kafka

类 KafkaProducer

java.lang.Object

xin.manong.weapon.base.kafka.KafkaProducer

public class KafkaProducer
extends Object

kafka消息生产

作者:

frankcl

构造器概要

构造器

构造器	说明
KafkaProducer(KafkaProduceConfig config)

方法概要

修饰符和类型	方法	说明
void	destroy()	销毁kafka消息生产
boolean	init()	初始化kafka消息生产
org.apache.kafka.clients.producer.RecordMetadata	send(byte[] message, String topic)	发送消息
org.apache.kafka.clients.producer.RecordMetadata	send(String key, byte[] message, String topic)	发送消息

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

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

构造器详细资料

KafkaProducer

public KafkaProducer(KafkaProduceConfig config)

方法详细资料

init

public boolean init()

初始化kafka消息生产

返回:

成功返回true，否则返回false

destroy

public void destroy()

销毁kafka消息生产

send

public org.apache.kafka.clients.producer.RecordMetadata send(String key,
                                                             byte[] message,
                                                             String topic)

发送消息

参数:

key - 消息key

message - 消息内容

topic - kafka topic

返回:

发送成功返回kafka元信息，否则返回null

send

public org.apache.kafka.clients.producer.RecordMetadata send(byte[] message,
                                                             String topic)

发送消息

参数:

message - 消息内容

topic - kafka topic

返回:

发送成功返回kafka元信息，否则返回null