Hi Jon, This is expected, see this: https://groups.google.com/forum/?pli=1#!searchin/confluent-platform/migrated$20to$20another$20instance%7Csort:relevance/confluent-platform/LglWC_dZDKw/qsPuCRT_DQAJ <https://groups.google.com/forum/?pli=1#!searchin/confluent-platform/migrated$20to$20another$20instance|sort:relevance/confluent-platform/LglWC_dZDKw/qsPuCRT_DQAJ>.
Thanks Eno > On 24 Mar 2017, at 20:51, Jon Yeargers <jon.yearg...@cedexis.com> wrote: > > I've setup a KTable as follows: > > KTable<Windowed<String>, String> outTable = sourceStream.groupByKey(). > reduce(rowReducer, > TimeWindows.of(5 * 60 * 1000L).advanceBy(1 * 60 * > 1000).until(10 * 60 * 1000L), > "AggStore"); > > I can confirm its presence via 'streams.allMetadata()' (accessible through > a simple httpserver). > > When I call 'ReadOnlyKeyValueStore<String, String> store = > kafkaStreams.store("AggStore", QueryableStoreTypes.keyValueStore());' > > I get this exception: > > org.apache.kafka.streams.errors.InvalidStateStoreException: the state > store, AggStore, may have migrated to another instance. > at > org.apache.kafka.streams.state.internals.QueryableStoreProvider.getStore(QueryableStoreProvider.java:49) > at > org.apache.kafka.streams.KafkaStreams.store(KafkaStreams.java:378) > at > com.cedexis.videokafka.videohouraggregator.RequestHandler.handle(RequestHandler.java:97) > at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:79) > at sun.net.httpserver.AuthFilter.doFilter(AuthFilter.java:83) > at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:82) > at > sun.net.httpserver.ServerImpl$Exchange$LinkHandler.handle(ServerImpl.java:675) > at com.sun.net.httpserver.Filter$Chain.doFilter(Filter.java:79) > at sun.net.httpserver.ServerImpl$Exchange.run(ServerImpl.java:647) > at > sun.net.httpserver.ServerImpl$DefaultExecutor.execute(ServerImpl.java:158) > at > sun.net.httpserver.ServerImpl$Dispatcher.handle(ServerImpl.java:431) > at sun.net.httpserver.ServerImpl$Dispatcher.run(ServerImpl.java:396) > at java.lang.Thread.run(Thread.java:745) > > > ... except.. there is only one instance.. running locally.