KafkaMQCallBack

java.lang.Object

com.sh.wf.mq.kafka.KafkaMQCallBack

public abstract class KafkaMQCallBack extends Object

Description: 消息监听回调方法

Title:首亨软件 - 聚天平台

从以下版本开始:: 2022年12月09日

构造器概要

构造器

构造器

说明

KafkaMQCallBack()
方法概要

修饰符和类型

方法

说明

org.apache.kafka.clients.consumer.KafkaConsumer<String,String>

getKafkaConsumer()

org.apache.kafka.clients.consumer.ConsumerRecords<String,String>

getRecords()

boolean

isRetry()

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

boolean

isStop()

是否退出监听

abstract boolean

receiveMsg(org.apache.kafka.clients.consumer.ConsumerRecords<String,String> records)

void

setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<String,String> kafkaConsumer)

void

setRecords(org.apache.kafka.clients.consumer.ConsumerRecords<String,String> records)

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料
- KafkaMQCallBack
  
  public KafkaMQCallBack()
方法详细资料
- receiveMsg
  
  public abstract boolean receiveMsg(org.apache.kafka.clients.consumer.ConsumerRecords<String,String> records)
- isRetry
  
  public boolean isRetry()
  
  是否重试,只有在出错或receiveMsg()方法返回false时，才会调用该方法
  
  返回:
  
  boolean
- isStop
  
  public boolean isStop()
  
  是否退出监听
  
  返回:
- getKafkaConsumer
  
  public org.apache.kafka.clients.consumer.KafkaConsumer<String,String> getKafkaConsumer()
- setKafkaConsumer
  
  public void setKafkaConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<String,String> kafkaConsumer)
- getRecords
  
  public org.apache.kafka.clients.consumer.ConsumerRecords<String,String> getRecords()
- setRecords
  
  public void setRecords(org.apache.kafka.clients.consumer.ConsumerRecords<String,String> records)