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

类 KafkaMQConsumer

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQBase

com.sh.wf.mq.kafka.KafkaMQConsumer

public class KafkaMQConsumer
extends KafkaMQBase

Description:

Title:首亨软件 - 聚天平台

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	KafkaMQConsumer.ConsumerPropBuilder

字段概要

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

AUTH, AUTH_IGNORE, DEFAULT_GROUP_ID, DEFAULT_TOPIC, topic

方法概要

修饰符和类型	方法	说明
void	close()
org.apache.kafka.clients.consumer.KafkaConsumer<String,String>	connect(Properties prop)
static KafkaMQConsumer	getInstance(String topic)
org.apache.kafka.clients.consumer.ConsumerRecords<String,String>	getMessage(Duration timeout)	获取一次消息列表
void	subscribe(KafkaMQCallBack callback)
void	subscribe(KafkaMQConsumer.ConsumerPropBuilder builder, KafkaMQCallBack callback)
boolean	subscribe(Properties prop, KafkaMQCallBack callback)	订阅消息

从类继承的方法 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 KafkaMQConsumer getInstance(String topic)

connect

public org.apache.kafka.clients.consumer.KafkaConsumer<String,String> connect(Properties prop)

subscribe

public void subscribe(KafkaMQCallBack callback)

subscribe

public void subscribe(KafkaMQConsumer.ConsumerPropBuilder builder,
 KafkaMQCallBack callback)

subscribe

public boolean subscribe(Properties prop,
 KafkaMQCallBack callback)

订阅消息

参数:

prop -

groupId -

callback -

getMessage

public org.apache.kafka.clients.consumer.ConsumerRecords<String,String> getMessage(Duration timeout)

获取一次消息列表

参数:

timeout -

返回:

close

public void close()