com.sh.wf.mq.kafka

类 KafkaMQCallBack

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQCallBack

public abstract class KafkaMQCallBack
extends java.lang.Object

Description: 消息监听回调方法

Title:首亨软件 - 聚天平台

从以下版本开始:

2022年12月09日

版本:

3.0

作者:

江兴春

构造器概要

构造器

构造器和说明
KafkaMQCallBack()

方法概要

限定符和类型	方法和说明
org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String>	getKafkaConsumer()
org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String>	getRecords()
boolean	isRetry() 是否重试,只有在出错或receiveMsg()方法返回false时，才会调用该方法
boolean	isStop() 是否退出监听
abstract boolean	receiveMsg(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)
void	setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> kafkaConsumer)
void	setRecords(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)

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

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

构造器详细资料

KafkaMQCallBack

public KafkaMQCallBack()

方法详细资料

receiveMsg

public abstract boolean receiveMsg(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)

isRetry

public boolean isRetry()

是否重试,只有在出错或receiveMsg()方法返回false时，才会调用该方法

返回:

boolean

isStop

public boolean isStop()

是否退出监听

返回:

getKafkaConsumer

public org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> getKafkaConsumer()

setKafkaConsumer

public void setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> kafkaConsumer)

getRecords

public org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> getRecords()

setRecords

public void setRecords(org.apache.kafka.clients.consumer.ConsumerRecords<java.lang.String,java.lang.String> records)