'Kafka Streams: Invalid State store Exception
While accessing state store in Kafka I'm getting an error.
Note: I haven't explicitly defined a stateStore.close() method in my code. Also, in the first 10-15 mins it runs fine but after 10-15 mins of running, it starts giving the error.
Error:
Caused by: org.apache.kafka.streams.errors.InvalidStateStoreException: Store primary-event-state-store is currently closed
at org.apache.kafka.streams.state.internals.RocksDBStore.validateStoreOpen(RocksDBStore.java:220)
at org.apache.kafka.streams.state.internals.RocksDBStore.get(RocksDBStore.java:214)
at org.apache.kafka.streams.state.internals.RocksDBStore.get(RocksDBStore.java:68)
at org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore.get(InnerMeteredKeyValueStore.java:183)
at org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore.get(MeteredKeyValueBytesStore.java:112)
at com.delhivery.stream.kengic.sorter.core.BagSealEventProcessor.processBagContents(BagSealEventProcessor.java:237)
at com.delhivery.stream.kengic.sorter.core.BagSealEventProcessor.punctuate(BagSealEventProcessor.java:164)
at org.apache.kafka.streams.processor.internals.ProcessorNode$4.run(ProcessorNode.java:131)
at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:211)
at org.apache.kafka.streams.processor.internals.ProcessorNode.punctuate(ProcessorNode.java:134)
at org.apache.kafka.streams.processor.internals.StreamTask.punctuate(StreamTask.java:271)
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|