prabhu biradar created KAFKA-13400:
--------------------------------------
Summary: offset() is not supported in standby tasks.
Key: KAFKA-13400
URL: https://issues.apache.org/jira/browse/KAFKA-13400
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.8.1
Reporter: prabhu biradar
Hi,
We are facing below exception in production, post upgrade to 2.8.1
this should not happen: offset() is not supported in standby tasks.
java.lang.UnsupportedOperationException: this should not happen: offset() is
not supported in standby tasks.
at
org.apache.kafka.streams.processor.internals.ProcessorContextImpl.throwUnsupportedOperationExceptionIfStandby(ProcessorContextImpl.java:360)
at
org.apache.kafka.streams.processor.internals.ProcessorContextImpl.offset(ProcessorContextImpl.java:330)
at
org.apache.kafka.streams.state.internals.CachingKeyValueStore.putInternal(CachingKeyValueStore.java:154)
at
org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:139)
at
org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:43)
at
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$put$4(MeteredKeyValueStore.java:200)
at
org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:879)
at
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.put(MeteredKeyValueStore.java:200)
at
org.apache.kafka.streams.processor.internals.AbstractReadWriteDecorator$KeyValueStoreReadWriteDecorator.put(AbstractReadWriteDecorator.java:120)
at
com.siriusxm.rtp.event.impl.DefaultStateStoreManager.putEvent(DefaultStateStoreManager.java:262)
at
com.siriusxm.rtp.event.impl.DefaultStateStoreManager.putEvent(DefaultStateStoreManager.java:270)
at
com.siriusxm.rtp.event.impl.DefaultStateStoreManager$$FastClassBySpringCGLIB$$5d9d5a55.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
