程序包 com.sh.wf.mq.kafka

类 KafkaMQProducer

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQBase

com.sh.wf.mq.kafka.KafkaMQProducer

public class KafkaMQProducer
extends KafkaMQBase

Description: kafka消息生产者

Title:首亨软件 - 聚天平台

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	KafkaMQProducer.ProducerPropBuilder

字段概要

从类继承的字段 com.sh.wf.mq.kafka.KafkaMQBase

AUTH, AUTH_IGNORE, DEFAULT_GROUP_ID, DEFAULT_TOPIC, topic

方法概要

修饰符和类型	方法	说明
void	close()
org.apache.kafka.clients.producer.KafkaProducer<String,String>	connect(Properties prop)
static KafkaMQProducer	getInstance(String topic)
boolean	sendMessage(String msg)	发送消息
boolean	sendMessage(Properties prop, String msg)	发送消息
boolean	sendMessageSecurity(String msg)
boolean	sendMessageSecurity(Properties prop, String msg)	安全的发送消息，连接将会自动关闭

从类继承的方法 com.sh.wf.mq.kafka.KafkaMQBase

checkPropBase, getBootstrapServers, setPropValue

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

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

方法详细资料

getInstance

public static KafkaMQProducer getInstance(String topic)

connect

public org.apache.kafka.clients.producer.KafkaProducer<String,String> connect(Properties prop)

sendMessage

public boolean sendMessage(String msg)

发送消息

参数:

msg - String

返回:

boolean

sendMessage

public boolean sendMessage(Properties prop,
 String msg)

发送消息

参数:

msg - String

返回:

boolean

sendMessageSecurity

public boolean sendMessageSecurity(String msg)

sendMessageSecurity

public boolean sendMessageSecurity(Properties prop,
 String msg)

安全的发送消息，连接将会自动关闭

参数:

prop -

msg -

返回:

close

public void close()