apache kafka – java.lang.UnsupportedOperationException: getPosition is not implemented by this StateStore
NAjava.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.put(ChangeLoggingKeyValueBytesStore.java:79)
at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:33)
Please let us know the alternative for this method in Kafka
Read more here: Source link
