我正在使用 Apache Beam 的 KafkaIO 来读取 Kafka 主题。一切都按预期工作，但如果我的工作被终止并重新启动，新工作会生成一个新的 groupID，因此它最终会从主题的开头读取。
换句话说，如果我的初始工作有group.id = Reader-0_offset_consumer_11111111_my_group作为 groupID，那么下一个工作可能最终有group.id = Reader-0_offset_consumer_22222222_my_group这个。如您所见，在我指定的 my_group之前添加了一些独特的前缀。有什么办法可以避免这种情况并每次都保持相同的组 id？谢谢