只是為了澄清，我是卡夫卡的新手，很抱歉，如果我的問題似乎沒有記錄，我正在閱讀教程、文檔和我能理解的一切。我試圖從 GlobalStore 讀取所有值以更新其值，然后使用已存在的 StateStore 來放置這些新的更新值。我正在嘗試這樣做，因為當我這樣做時：this.stateStore.all();我只有1/10的數據，如果我理解正確的話，這是因為我有10個分區，而ss，只讀取一個（雖然我不太明白為什么）這是我的全局表：    public StreamsBuilder declareTopology(StreamsBuilder builder) {        logger.debug("Building topology : input topic ~ {} ; output topics ~ {}, {}",                getInputTopic(),                getDataTopic(),                getToEsTopic());        builder.globalTable(                getDataTopic(),                Consumed.with(Serdes.String(), fooSerdes)                        .withOffsetResetPolicy(Topology.AutoOffsetReset.EARLIEST),                Materialized.<String, Foo, KeyValueStore<Bytes, byte[]>>as(                        "foosktable")                        .withKeySerde(Serdes.String())                        .withValueSerde(fooSerdes)                        .withLoggingEnabled(new HashMap<>()));    ...這是 addStateStore，我無法刪除它，因為它在代碼的其他地方使用：       ...       builder.addStateStore(            Stores.keyValueStoreBuilder(                    Stores.persistentKeyValueStore("foosktable"),                    Serdes.String(),                    fooSerdes));    ...    return builder;}因此，從理論上講，我想做的是刪除也使用相同主題的 StateStore，并使用我的 data.process 主題之一放置我的數據，問題是該處理器使用此 StateStore 執行其他操作，所以我不能用核武器攻擊它。我在這里迷路了，任何光都會有很大幫助。謝謝 ！