大山

0 声望

这家伙太懒,什么都没留下

个人动态
  • 大山 回复 半兽人Kafka Stream演示程序 中 :

    if (loggingEnabled) {
                throw new TopologyException("StateStore " + storeName + " for global table must not have logging enabled.");
            }
    也许kafka觉得全局的stateStore不需要持久化了吧,因为各个partition的statestore已经持久化了,全局的只是用于做一次归集,就算每次都计算下也不会有太大的开销

    5年前
  • 大山 回复 半兽人Kafka Stream演示程序 中 :

    这些store是可以支持持久化的,但是new Topology().addGlobalStore()【这个就是公共存储】传入的Stores.xxxxStore()不能是enableLoggging的

    5年前
  • 半兽人 回复 大山Kafka Stream演示程序 中 :

    Stores.create(STATE_STORE) ?

    5年前
  • 大山 回复 半兽人Kafka Stream演示程序 中 :

    公共存储不支持logging持久化的,没有容错

    5年前
  • 半兽人 回复 大山Kafka Stream演示程序 中 :

    不会的,有公共存储的。

    5年前