search

a0x8o / kafka

A high-throughput, distributed, publish-subscribe messaging system
Apache License 2.0
67 stars 171 forks source link

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

Open Shalaka1197 opened 7 months ago

Shalaka1197 commented 7 months ago

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 ?