public interface KafkaBatchContext
| 限定符和类型 | 方法和说明 |
|---|---|
void |
addContext(KafkaContext context)
新增消费上下文
|
Object |
getAttribute(String key)
获取一个属性
|
Map<String,Object> |
getAttributes()
获取全部属性
|
List<KafkaContext> |
getContexts()
获取全部消费上下文
|
void |
setAttribute(String key,
Object value)
新增一个属性
|
List<KafkaContext> getContexts()
void addContext(KafkaContext context)
context - 消费上下文Copyright © 2023. All rights reserved.