[jira] [Resolved] (KAFKA-13400) offset() is not supported in standby tasks.

["Matthias J. Sax (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax resolved KAFKA-13400.
-------------------------------------
    Resolution: Not A Bug

Based on the information provided, the conclusion seems to be that a state store handle is passed to a different thread, and that the state store is accessed from outside of the `StreamThread` context. – This is an invalid usage pattern, and thus there seems to be no bug in Kafka Streams.

> 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
>            Priority: Major
>
> 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.20.1#820001)