kafka
kafka copied to clipboard
UnsupportedOperationException exception is getting in put and delete operations "getPosition is not implemented by this StateStore."
I am getting below exceptions when I am doing put and delete operations of state store.
Ajava.lang.UnsupportedOperationException: getPosition is not implemented by this StateStore at org.apache.kafka.streams.processor.StateStore.getPosition(StateStore.java:165) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.log(ChangeLoggingKeyValueBytesStore.java:142) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.delete(ChangeLoggingKeyValueBytesStore.java:110) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.delete(ChangeLoggingKeyValueBytesStore.java:33) at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$delete$10(MeteredKeyValueStore.java:381) at org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:819) at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.delete(MeteredKeyValueStore.java:381) at
This is getting from below method. Is there any alternate method available for this ?