io.github.changebooks.kafka

接口 KafkaBatchConsumer

函数接口:

这是一个函数接口, 因此可用作 lambda 表达式或方法引用的赋值目标。

@FunctionalInterface
public interface KafkaBatchConsumer

批量消费

作者:

changebooks@qq.com

方法概要

限定符和类型	方法和说明
boolean	consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records, KafkaBatchContext context) 执行消费

方法详细资料

consume

boolean consume(List<org.apache.kafka.clients.consumer.ConsumerRecord<String,String>> records,
                @Nullable
                KafkaBatchContext context)

执行消费

参数:

records - 消息列表

context - 消费上下文

返回:

消费成功提交消息？否则，消费失败等待重试，或抛出异常等待重试