commit 08e27914ccf492e32c7fff652f32236b2dce8928
author Bruno Cadonna <cadonna@apache.org> Fri Jun 24 12:19:22 2022 +0200
committer GitHub <noreply@github.com> Fri Jun 24 12:19:22 2022 +0200
tree 40494d6eda3e0bb109db33b38f7470746020f1e9
parent cf9c3a2ecaf0b6abf00194334157a1e94ff9f618

HOTFIX: Fix NPE in StreamTask#shouldCheckpointState (#12341)

The mocks were not setup correctly in StreamTask#shouldCheckpointState
which caused a null pointer exception during test execution.

streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
index 2fb87a5..3f9a2cb 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
@@ -1951,7 +1951,9 @@
         EasyMock.expectLastCall().once();
         stateManager.checkpoint();
         EasyMock.expectLastCall().once();
-        EasyMock.replay(stateManager);
+        EasyMock.expect(stateManager.changelogOffsets()).andStubReturn(Collections.emptyMap());
+        EasyMock.expect(recordCollector.offsets()).andStubReturn(Collections.emptyMap());
+        EasyMock.replay(stateManager, recordCollector);
 
         task = createOptimizedStatefulTask(createConfig("100"), consumer);