io.github.changebooks.kafka

接口 KafkaBatchContext

所有已知实现类:

KafkaBatchContextImpl

public interface KafkaBatchContext

批量消费上下文

作者:

changebooks@qq.com

方法概要

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

方法详细资料

getContexts

List<KafkaContext> getContexts()

获取全部消费上下文

返回:

消费上下文列表

addContext

void addContext(KafkaContext context)

新增消费上下文

参数:

context - 消费上下文

getAttributes

Map<String,Object> getAttributes()

获取全部属性

返回:

属性列表

getAttribute

Object getAttribute(String key)

获取一个属性

参数:

key - 属性名

返回:

属性值

setAttribute

void setAttribute(String key,
                  Object value)

新增一个属性

参数:

key - 属性名

value - 属性值