From ede560263cbc27a45895b7a106ada0976ab6f9e0 Mon Sep 17 00:00:00 2001 From: wunameya <81896026+wunameya@users.noreply.github.com> Date: Wed, 26 Mar 2025 09:19:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E9=94=99=E5=88=AB=E5=AD=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/src/interview/kafka-40.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/src/interview/kafka-40.md b/docs/src/interview/kafka-40.md index 441f5176fc..b75165bd93 100644 --- a/docs/src/interview/kafka-40.md +++ b/docs/src/interview/kafka-40.md @@ -195,7 +195,7 @@ Consumer Group与Consumer的关系是动态维护的,当一个Consumer进程 ## 18、Consumer 如何消费指定分区消息 -Cosumer 消费消息时,想Broker 发出 `fetch` 请求去消费特定分区的消息,Consumer 可以通过指定消息在日志中的偏移量 offset,就可以从这个位置开始消息消息,Consumer 拥有了 offset 的控制权,也可以向后回滚去重新消费之前的消息。 +Cosumer 消费消息时,向Broker 发出 `fetch` 请求去消费特定分区的消息,Consumer 可以通过指定消息在日志中的偏移量 offset,就可以从这个位置开始消费消息,Consumer 拥有了 offset 的控制权,也可以向后回滚去重新消费之前的消息。 也可以使用 `seek(Long topicPartition)` 来指定消费的位置。 @@ -401,4 +401,4 @@ GitHub 上标星 10000+ 的开源知识库《[二哥的 Java 进阶之路](https 微信搜 **沉默王二** 或扫描下方二维码关注二哥的原创公众号沉默王二,回复 **222** 即可免费领取。 -![](https://cdn.tobebetterjavaer.com/tobebetterjavaer/images/gongzhonghao.png) \ No newline at end of file +![](https://cdn.tobebetterjavaer.com/tobebetterjavaer/images/gongzhonghao.png)