如果不从头开始阅读，Kafka 就无法消费 -Java
Kafka not able to consume without reading from beginning -Java
我是 kafka 的新手，正在尝试使用 kafka 构建生产者-消费者应用程序。在这里，我能够向 kalka 生成消息，但是当我尝试使用消费者消费它时，它返回 0 条记录。
我检查我的消费者组的偏移量，我可以看到偏移量等于日志长度是相同的（在我的例子中是 1M - 与记录数相同）。
如果我在创建消费者时使用此配置 属性，它会从头开始读取。
configProperties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
但我的要求是，如果我重启消费者，它应该像AMQ一样从之前的终点开始。
这里有什么我遗漏的吗？我认为抵消应该只在消费者投票后改变。为什么在开始时将其设置为最大记录长度？
正如 link 所述，您需要考虑以下几种情况：
starting a new consumer(newgroup.id)：对于这种情况，不会有committed offset，因此consumer会根据参数设置开始读取auto.offset.reset
重启消费者（重用group.id）：在这种情况下，消费者将从它停止的地方恢复。参数设置auto.offset.reset被忽略。
因此，对于场景 (1)，您可以 "configure" 您的起始位置。对于场景 (2)，您的起始位置是 "fixed"（即，始终是最后提交的偏移量）并且无法通过配置更改。但是，您始终可以在首次调用 poll() 之前执行 .seekToBeginning() 或 .seekToEnd() 并阅读整个主题或从主题的末尾开始。调用 .seekXX() 将 "overwrite" 最后提交的偏移量，并允许您以您喜欢的任何偏移量开始消费。请注意，还有 seek() 取代 "offset parameter"，因此您可以指定要开始使用的任何偏移量。
我是 kafka 的新手，正在尝试使用 kafka 构建生产者-消费者应用程序。在这里，我能够向 kalka 生成消息，但是当我尝试使用消费者消费它时，它返回 0 条记录。
我检查我的消费者组的偏移量，我可以看到偏移量等于日志长度是相同的（在我的例子中是 1M - 与记录数相同）。
如果我在创建消费者时使用此配置 属性，它会从头开始读取。
configProperties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
但我的要求是，如果我重启消费者，它应该像AMQ一样从之前的终点开始。
这里有什么我遗漏的吗？我认为抵消应该只在消费者投票后改变。为什么在开始时将其设置为最大记录长度？
正如 link 所述，您需要考虑以下几种情况：
starting a new consumer(new
group.id)：对于这种情况，不会有committed offset，因此consumer会根据参数设置开始读取auto.offset.reset重启消费者（重用
group.id）：在这种情况下，消费者将从它停止的地方恢复。参数设置auto.offset.reset被忽略。
因此，对于场景 (1)，您可以 "configure" 您的起始位置。对于场景 (2)，您的起始位置是 "fixed"（即，始终是最后提交的偏移量）并且无法通过配置更改。但是，您始终可以在首次调用 poll() 之前执行 .seekToBeginning() 或 .seekToEnd() 并阅读整个主题或从主题的末尾开始。调用 .seekXX() 将 "overwrite" 最后提交的偏移量，并允许您以您喜欢的任何偏移量开始消费。请注意，还有 seek() 取代 "offset parameter"，因此您可以指定要开始使用的任何偏移量。