File tree Expand file tree Collapse file tree 1 file changed +0
-3
lines changed
streams/src/test/java/org/apache/kafka/streams/processor/internals Expand file tree Collapse file tree 1 file changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -2928,7 +2928,6 @@ public void shouldNotCompleteRestorationIfTaskCannotCompleteRestoration() {
29282928 verify (task00 ).completeRestoration (any ());
29292929 verify (stateUpdater ).add (task00 );
29302930 verify (tasks , never ()).addTask (task00 );
2931- verify (consumer , never ()).resume (task00 .inputPartitions ());
29322931 verifyNoInteractions (consumer );
29332932 }
29342933
@@ -2946,8 +2945,6 @@ public void shouldSuspendActiveTasksDuringRevocation() {
29462945
29472946 when (task00 .commitNeeded ()).thenReturn (true );
29482947 when (task00 .prepareCommit (true )).thenReturn (offsets );
2949- doNothing ().when (task00 ).postCommit (true );
2950- doNothing ().when (task00 ).suspend ();
29512948
29522949 final TaskManager taskManager = setUpTaskManagerWithStateUpdater (ProcessingMode .AT_LEAST_ONCE , tasks );
29532950
You can’t perform that action at this time.
0 commit comments