大山

0 声望

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

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

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

    6年前
  • 大山 回复 半兽人 在 Kafka Stream演示程序 中 ：

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

    6年前
  • 半兽人 回复 大山 在 Kafka Stream演示程序 中 ：

    Stores.create(STATE_STORE) ？

    6年前
  • 大山 回复 半兽人 在 Kafka Stream演示程序 中 ：

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

    6年前
  • 半兽人 回复 大山 在 Kafka Stream演示程序 中 ：

    不会的，有公共存储的。

    6年前