Kafka 手动设置 offset 偏移量

小渣渣

查看某个 topic 详情

登录可见。

回顾：

.NET/C# 消息队列之 Kafka 操作[附源码]
https://www.itsvse.com/thread-9619-1-1.html

前提条件：相关所有消费服务必须停止。

执行如下命令即可：

首先查看指定消费组信息下面使用的 topic offset 偏移量情况：

登录可见。

注意看 current-offset 和 log-end-offset 还有 lag ，分别为当前偏移量，结束的偏移量，落后的偏移量。

现在明显是 lag 为10546，current-offset = 10544，log-end-offset=21090，告诉我们有 10546 条未消费

CURRENT-OFFSET：当前已经消费到偏移量为 10544 ,可以理解为已经消费 10544 条。

LOG-END-OFFSET：可以理解为总共 21090 条记录。

LAG：可以理解为未消费记录条数。

手动设置 offset 偏移量

登录可见。

再次查看组的消费情况，如下：

登录可见。

只有 3 条消息未消费，我们打开消费端程序运行，如下图：



只消费了剩余的 3 条消息，手动调节偏移量成功了。

（完）