[
https://issues.apache.org/jira/browse/KAFKA-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434385#comment-17434385
]
prabhu commented on KAFKA-13400:
--------------------------------
here is the complete stack trace.
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)
at
org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at
org.springframework.aop.aspectj.AspectJAfterThrowingAdvice.invoke(AspectJAfterThrowingAdvice.java:62)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at
org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:93)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)
at
com.siriusxm.rtp.event.impl.DefaultStateStoreManager$$EnhancerBySpringCGLIB$$506c3de2.putEvent(<generated>)
at
com.siriusxm.rtp.event.AccountStateManager.doCachedUpdate(AccountStateManager.java:127)
at
com.siriusxm.rtp.handler.account.AccountStateHelper.processAccount(AccountStateHelper.java:97)
at
com.siriusxm.rtp.handler.account.AccountStateHelper.calculateAllUpdates(AccountStateHelper.java:56)
at
com.siriusxm.rtp.event.AccountStateProcessor.processAccountState(AccountStateProcessor.java:71)
at
com.siriusxm.rtp.event.AccountStateManager.performAction(AccountStateManager.java:172)
at
com.siriusxm.rtp.event.impl.DefaultEventOrderHandler.handle(DefaultEventOrderHandler.java:64)
at
com.siriusxm.rtp.event.impl.DefaultEventOrderHandler$$FastClassBySpringCGLIB$$bc1f576e.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at
org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at
org.springframework.aop.aspectj.AspectJAfterThrowingAdvice.invoke(AspectJAfterThrowingAdvice.java:62)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at
org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:93)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)
at
com.siriusxm.rtp.event.impl.DefaultEventOrderHandler$$EnhancerBySpringCGLIB$$a4c8accd.handle(<generated>)
at
com.siriusxm.rtp.streams.OpCodeStreamingJob.handleEvent(OpCodeStreamingJob.java:260)
at
com.siriusxm.rtp.streams.OpCodeStreamingJob.processBusinessEvent(OpCodeStreamingJob.java:232)
at
com.siriusxm.rtp.streams.OpCodeStreamingJob.businessProcess(OpCodeStreamingJob.java:189)
at
com.siriusxm.rtp.streams.OpCodeStreamingJob.lambda$processWithTimeOut$0(OpCodeStreamingJob.java:149)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
> 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)
