[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435633#comment-17435633
]
prabhu commented on KAFKA-13400:
--------------------------------
DefaultStateStoreManager - This Class contains methods that manage state store
operations for an account.
* E.g. for account number 1234:
* 1234 - the account number itself stores account state
Note that events are stored using account number and sequence ID.
part of this class we have method called putAccountstate which takes account
number as key and accountstate object as value and using stateStore.put method
we store these values in state store.
> 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.3.4#803005)
