来自主题的 KTable 和服务重启

Question

我很困惑所以在这里问这个问题。

1. 从 Kafka 主题 T1 创建一个 Ktable K1。从偏移量 0 读取到最新偏移量。
2. Topic T1 由其他服务生成，此处仅用于创建 KTable K1
3. 我重新启动我的服务
4. 我了解 Ktable K1 将被重新创建，我的问题是

问。 KTable K1 是否会再次拥有来自主题 T1 的所有数据，或者 table 消费者将保留偏移量并忽略来自主题 T1 的已消费消息？

Answer 1

KTable K1 将包含主题 T1 的所有数据。