consumer

大家好，我是君哥。 最近有读者参加面试时被问了一个问题，如果消费者拉取了一批消息，比如 100 条，第 100 条消息消费成功了，但是第 50 条消费失败，偏移量会怎样更新？就着这个问题，今天来聊一下，如果一批消息有消费失败的情况时，偏移量怎么保存。 1 拉取消息 1.1 封装拉取请求 以 Rock…

java中的consumer接口用于定义不返回结果的操作，其核心目的是简化代码并提升可读性与维护性。1. 它常用于集合的foreach方法，实现更简洁的遍历操作；2. 在stream api中通过peek和foreach方法支持中间处理与最终操作；3. 可自定义多参数consumer接口以满足特定需…