一个可能的解决方案是，通过手动将偏移量提交到数据库，存储您希望不同使用者从中开始的点。
一张table看起来像：

Topic  Partition  Offset

topicA 0          112
topicA 1          125
topicB 0          2313
topicB 1          2984
topicB 2          2554

这些将是你的“最新重置”点，或立场，你的消费者想要开始。问题在于 subscribe() 方法，正如您所说的，是它依赖于group.id参数，并执行消费者再平衡和协调游戏。
为了从固定点（或不同分区中的一组点）进行消费，应该调用 assign() 相反。使用此方法，您可以手动为使用者指定分区列表。没有group.id，没有动态分区分配，也没有偏移量加载，这正是您需要的。
分配分区后，应该调用 seek() . 使用seek，您可以告诉使用者要从哪个偏移量开始读取在上指定的分区 assign() 方法。
例如，要开始阅读任何主题的“最新重置”，您应该执行以下操作：

//seeking the last offset of topicA's partition0
public void setStartPosition(TopicPartition partition, long offset) 
{
     consumer.assign(Collections.singletonList(partition)); //f.e-> partition0
     consumer.seek(partition, offset);                      //f.e -> 112
}

调用此方法将使使用者准确地定位在每个分区中所需的位置。我不确定我是否回答了你的问题，但希望能有所帮助！