io.github.changebooks.kafka

类 KafkaBatchContextImpl

java.lang.Object

io.github.changebooks.kafka.KafkaBatchContextImpl

所有已实现的接口:

KafkaBatchContext

public class KafkaBatchContextImpl
extends Object
implements KafkaBatchContext

批量消费上下文的默认实现

作者:

changebooks@qq.com

构造器概要

构造器

构造器和说明
KafkaBatchContextImpl()

方法概要

限定符和类型	方法和说明
void	addContext(KafkaContext context) 新增消费上下文
Object	getAttribute(String key) 获取一个属性
Map<String,Object>	getAttributes() 获取全部属性
List<KafkaContext>	getContexts() 获取全部消费上下文
void	setAttribute(String key, Object value) 新增一个属性

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

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

构造器详细资料

KafkaBatchContextImpl

public KafkaBatchContextImpl()

方法详细资料

getContexts

public List<KafkaContext> getContexts()

从接口复制的说明: KafkaBatchContext

获取全部消费上下文

指定者:

getContexts 在接口中 KafkaBatchContext

返回:

消费上下文列表

addContext

public void addContext(KafkaContext context)

从接口复制的说明: KafkaBatchContext

新增消费上下文

指定者:

addContext 在接口中 KafkaBatchContext

参数:

context - 消费上下文

getAttributes

public Map<String,Object> getAttributes()

从接口复制的说明: KafkaBatchContext

获取全部属性

指定者:

getAttributes 在接口中 KafkaBatchContext

返回:

属性列表

getAttribute

public Object getAttribute(String key)

从接口复制的说明: KafkaBatchContext

获取一个属性

指定者:

getAttribute 在接口中 KafkaBatchContext

参数:

key - 属性名

返回:

属性值

setAttribute

public void setAttribute(String key,
                         Object value)

从接口复制的说明: KafkaBatchContext

新增一个属性

指定者:

setAttribute 在接口中 KafkaBatchContext

参数:

key - 属性名

value - 属性值