kafka icon indicating copy to clipboard operation
kafka copied to clipboard

UnsupportedOperationException exception is getting in put and delete operations "getPosition is not implemented by this StateStore."

Open Shalaka1197 opened this issue 1 year ago • 0 comments

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 ?

Shalaka1197 avatar Nov 21 '23 06:11 Shalaka1197