当调用 commitOffsets 时，从 KafkaStream 下一次调用拉取的最新消息的偏移量会提交什么值？或者消费者缓冲的最大偏移量的值或其他值？
最佳答案
它将是消费者获取的最大值(即客户端使用 next() 读取的值，不包括内部缓冲的值)。
但请注意，如果 Consumer 用于实例化多个迭代器以供多个线程使用，它们将同时提交 - 通常不是预期的行为，因为一个线程无法了解其他线程的处理状态。
关于apache-kafka - 当在 Kafka 高级 ConsumerConnector 上调用 commitOffsets 时，会提交什么值？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/26477585/