apache-kafka - 我们可以更新 kafka 0.10 中的消费者偏移量吗？

首页 > 解决方案 > 我们可以更新 kafka 0.10 中的消费者偏移量吗？

问题描述

我正在使用旧版本的 Kafka，0.10。有什么方法可以将主题的消费者偏移量更新为任意数字？

标签： apache-kafkakafka-consumer-api

解决方案

在 Kafka 0.10 中，我认为没有工具可以轻松更新消费者偏移量。

你基本上有2个选择：

使用更新的 Kafka 版本中的工具。如今，消费者偏移量可以使用kafka-consumer-groups.sh工具或更新AdminClient（目前仅在主干中，它将在 Kafka 2.5 中）。
编写一个启动消费者并调用commitSync()以更新其消费者偏移量的小型应用程序，例如ConsumerGroupCommand.resetOffsets()

推荐阅读