我建立了一个Kafka流应用程序与国家商店。现在我正在尝试扩展这个应用程序。当在三个不同的服务器上运行应用程序时，kafka会随机分割分区和状态存储。
例如：
instance1获取：partition-0，partition-1
instance2获取：partition-2，statestore-repartition-0
示例3获取：statestore-repartition-1、statestore-repartition-2
我想为每个示例分配一个statestore和一个分区。我做错什么了？
我的kafkastreams配置：

final Properties properties = new Properties();
properties.setProperty(StreamsConfig.APPLICATION_ID_CONFIG, "my-app");
properties.setProperty(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS_CONFIG);

try {
     properties.setProperty(StreamsConfig.STATE_DIR_CONFIG,
           Files.createTempDirectory(stateStoreName).toAbsolutePath().toString());
} catch (final IOException e) {
         // use the default one
}

我的流是：

stream.groupByKey()
       .windowedBy(TimeWindows.of(timeWindowDuration))
       .<TradeStats>aggregate(
           () -> new TradeStats(),
           (k, v, tradestats) -> tradestats.add(v),
           Materialized.<String, TradeStats, WindowStore<Bytes, byte[]>>as(stateStoreName)
        .withValueSerde(new TradeStatsSerde()))
        .toStream();