You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2022/06/24 04:12:35 UTC
[kafka] 01/02: fix surprising test failure
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a commit to branch john-revert-12049
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit b96e25c37d7e0735f957b402d02fbe95447ed0f7
Author: John Roesler <jo...@vvcephei.org>
AuthorDate: Thu Jun 23 23:00:28 2022 -0500
fix surprising test failure
---
.../apache/kafka/streams/processor/internals/StreamTaskTest.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
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 2fb87a5ae9..870a8f9a25 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,14 @@ public class StreamTaskTest {
EasyMock.expectLastCall().once();
stateManager.checkpoint();
EasyMock.expectLastCall().once();
- EasyMock.replay(stateManager);
+ stateManager.changelogOffsets();
+ EasyMock.expectLastCall().andReturn(emptyMap());
+
+ recordCollector.offsets();
+ EasyMock.expectLastCall().andReturn(emptyMap());
+
+ EasyMock.replay(stateManager, recordCollector);
+
task = createOptimizedStatefulTask(createConfig("100"), consumer);