KafkaStreamConfiguration.java

    @Bean
    public StoreBuilder<KeyValueStore<String, RangeEvent>> stateStoreBuilder(StreamsBuilder builder,
                                                                             SerdeService serdeService) {
        StoreBuilder<KeyValueStore<String, RangeEvent>> storeBuilder =
                Stores.keyValueStoreBuilder(
                        Stores.persistentKeyValueStore(STATE_STORE_NAME),
                        Serdes.String(),
                        serdeService.asJSON(RangeEvent.class)
                );

        builder.addStateStore(storeBuilder);
        return storeBuilder;
    }