io.github.changebooks.kafka

类 KafkaContext

java.lang.Object

io.github.changebooks.kafka.KafkaContext

所有已实现的接口:

Serializable

public final class KafkaContext
extends Object
implements Serializable

消费上下文

作者:

changebooks@qq.com

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
static int	SUCCESS_OK OK

构造器概要

构造器

构造器和说明
KafkaContext()

方法概要

限定符和类型	方法和说明
int	getCode()
String	getMessage()
org.apache.kafka.clients.consumer.ConsumerRecord<String,String>	getRecord()
boolean	isSuccess()
void	setCode(int code)
void	setMessage(String message)
void	setRecord(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)

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

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

字段详细资料

SUCCESS_OK

public static final int SUCCESS_OK

OK

另请参阅:

常量字段值

构造器详细资料

KafkaContext

public KafkaContext()

方法详细资料

isSuccess

public boolean isSuccess()

getCode

public int getCode()

setCode

public void setCode(int code)

getMessage

public String getMessage()

setMessage

public void setMessage(String message)

getRecord

public org.apache.kafka.clients.consumer.ConsumerRecord<String,String> getRecord()

setRecord

public void setRecord(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)