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:首亨软件 - 聚天平台

版本:

4.0

作者:

江兴春

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	KafkaMQProducer.ProducerPropBuilder

字段概要

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

AUTH, AUTH_IGNORE, DEFAULT_GROUP_ID, DEFAULT_TOPIC

方法概要

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

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

getBootstrapServers

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

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

方法详细资料

getInstance

public static KafkaMQProducer getInstance(java.lang.String topic)

connect

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

sendMessage

public boolean sendMessage(java.lang.String msg)

发送消息

参数:

msg - String

返回:

boolean

sendMessage

public boolean sendMessage(java.util.Properties prop,
                           java.lang.String msg)

发送消息

参数:

msg - String

返回:

boolean

sendMessageSecurity

public boolean sendMessageSecurity(java.lang.String msg)

sendMessageSecurity

public boolean sendMessageSecurity(java.util.Properties prop,
                                   java.lang.String msg)

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

参数:

prop -

msg -

返回:

close

public void close()

main

public static void main(java.lang.String[] args)