【发布时间】:2021-10-19 00:07:23
【问题描述】:
我很困惑所以在这里问这个问题。
- 从 Kafka 主题 T1 创建 Ktable K1。从偏移量 0 读取到最新的偏移量。
- 主题 T1 由其他服务生成,此处仅用于创建 KTable K1
- 我重新启动我的服务
- 我知道 Ktable K1 将被重新创建,我的问题是
问。 KTable K1 是否会再次拥有来自主题 T1 的所有数据,或者表消费者将保留偏移量并忽略来自主题 T1 的已消费消息?
【问题讨论】:
标签: apache-kafka kafka-consumer-api apache-kafka-streams confluent-platform