[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435214#comment-17435214
]
Matthias J. Sax commented on KAFKA-13400:
-----------------------------------------
[~grussell] – thanks for chiming in! – I agree that it seems to be a version
mismatch issue to some extent. If Spring 2.1.4 is not supported any longer,
upgrading to Kafka Streams 2.8 is not guaranteed to work.
Nevertheless, I am a little concerned about the stack trace. The first call to
Kafka Streams is from `DefaultStateStoreManager` to
`org.apache.kafka.streams.processor.internals.AbstractReadWriteDecorator$KeyValueStoreReadWriteDecorator.put()`which
is clearly an internal class (as indicated by the package name. Thus, it's
unclear how `DefaultStateStoreManager` even gets a reference to it. – My
suspicious is reflection (the root of all evil!). If anyone taps into internal
classes, you basically void your warranty :)
[~pbiradar] Can you clarify what `DefaultStateStoreManager` is? I suspect it's
your own code, and that you do something nasty?
Overall, it seems not to be a Kafka Streams bug (not a Spring issue), and I
would propose to close this ticket as invalid?
> 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)
