我使用的是c++rdkafka库。以前，我使用querywatermarkoffsets查找最高偏移量，然后检查具有该偏移量的消息是否已被使用，但结果表明这是不可靠的，因为存在可以跳过偏移量的情况（例如事务）。我正在考虑使用超时，但更喜欢确定性的东西。任何帮助都将不胜感激。