您几乎没有选择：
ktable，按购物车聚合（每个购物车不能有两次相同的产品）。为了防止这个增长太大，记录需要被“墓碑”，所以另一件事需要告诉应用程序购物车已经不存在了。
记住，要在kafka中进行任何类型的聚合，都需要本地存储。如果你不想或不能有本地存储，Kafka是错误的工具。
我不完全理解你的观点，但是微服务验证过程有问题。首先它说没有缓存或本地存储，第二点说加载所有内容（这意味着在本地存储中缓存）。
---编辑
您可以检查confluent中对订单进行验证的示例：https://github.com/confluentinc/kafka-streams-examples/tree/5.4.1-post/src/main/java/io/confluent/examples/streams/microservices .
如果我理解正确，您可以拥有一个没有变更日志的本地存储，这样您可以在重新启动时重新填充它。
检查inventoryservice.java类，在那里可以看到如何创建一个separe存储。您要省略的行是 .withLoggingEnabled() ，因为这样会创建一个changelog主题。

final StoreBuilder reservedStock = Stores
  .keyValueStoreBuilder(Stores.persistentKeyValueStore(RESERVED_STOCK_STORE_NAME),
    Topics.WAREHOUSE_INVENTORY.keySerde(), Serdes.Long())
builder.addStateStore(reservedStock);

你还需要做的两件事是：
将流配置为返回最早的记录 config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); 在构建流之前，有一些代码可以找到存储并擦除它。请查看confluent的这篇博文，这篇博文的一部分是LocalState存储，它解释了如何找到存储本地文件的目录，这样您就可以擦除目录了。