Skip to content

Revert "KAFKA-13722: remove usage of old ProcessorContext (#18292)" #20398

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: 4.1
Choose a base branch
from

Conversation

mjsax
Copy link
Member

@mjsax mjsax commented Aug 22, 2025

This reverts commit f13a22a.

@mjsax mjsax force-pushed the revert-f13a22af0b3a48a4ca1bf2ece5b58f31e3b26b7d branch from a978074 to 63c5c10 Compare August 22, 2025 21:11
@chia7712
Copy link
Member

Gradle Test Run :streams:test-utils:test > Gradle Test Executor 22 > TopologyTestDriverEosTest > shouldAllowPrePopulatingStatesStoresWithCachingEnabled() FAILED
    java.lang.NullPointerException: Cannot invoke "org.apache.kafka.streams.processor.internals.ProcessorRecordContext.sourceRawKey()" because the return value of "org.apache.kafka.streams.processor.internals.InternalProcessorContext.recordContext()" is null
        at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putInternal(CachingKeyValueStore.java:281)
        at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:261)
        at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:54)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.lambda$put$6(MeteredKeyValueStore.java:303)
        at org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl.maybeMeasureLatency(StreamsMetricsImpl.java:901)
        at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.put(MeteredKeyValueStore.java:303)
        at org.apache.kafka.streams.TopologyTestDriverTest.shouldAllowPrePopulatingStatesStoresWithCachingEnabled(TopologyTestDriverTest.java:1430)
        at java.base/java.lang.reflect.Method.invoke(Method.java:580)
        at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)
        at java.base/java.util.ArrayList.forEach(ArrayList.java:1596)

1 test completed, 1 failed

@mjsax could you please take a look at above failed test?

@mjsax mjsax force-pushed the revert-f13a22af0b3a48a4ca1bf2ece5b58f31e3b26b7d branch from 63c5c10 to d544010 Compare August 23, 2025 20:06
@mjsax
Copy link
Member Author

mjsax commented Aug 23, 2025

Pushed an update.

@mjsax mjsax added the streams label Aug 23, 2025
Copy link
Member

@chia7712 chia7712 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants