【问题标题】:KTable from a topic and service restart来自主题的 KTable 和服务重启
【发布时间】:2021-10-19 00:07:23
【问题描述】:

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

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

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

【问题讨论】:

    标签: apache-kafka kafka-consumer-api apache-kafka-streams confluent-platform


    【解决方案1】:

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

    【讨论】:

      猜你喜欢
      • 2016-05-22
      • 2020-07-17
      • 1970-01-01
      • 2011-09-01
      • 1970-01-01
      • 2019-08-11
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多