我们将ktable具体化为一个内部状态存储。
a、 ）如何以及在何处指定，此内部状态存储应是持久的，并自动备份到另一个Kafka主题？
b、 ）我们如何指定，这个内部状态存储应该是全局的，以便我的任何流任务都可以引用它？
c、 ）是否存在将传入的消息记录写入内部状态存储的频率？有没有可能，一个特定的消息记录被流处理器处理，存储在ktable中，然后我的流处理器就死了，它无法进入内部状态存储！！
下面是我们现在使用的代码片段：-

KTable<String, String> KT0 = streamsBuilder.table(AppConfigs.topicName, Materialized.as(AppConfigs.stateStoreName)));

如有任何回应，我们将不胜感激！！