added missing verification

shashankhs11 · shashankhs11 · commit 7d7463354b2a · 2025-11-04T14:38:28.000-08:00
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
@@ -2929,6 +2929,7 @@ public void shouldNotCompleteRestorationIfTaskCannotCompleteRestoration() {
         verify(stateUpdater).add(task00);
         verify(tasks, never()).addTask(task00);
         verify(consumer, never()).resume(task00.inputPartitions());
+        verifyNoInteractions(consumer);
     }
 
     @Test

Original file line number	Diff line number	Diff line change
`@@ -2929,6 +2929,7 @@ public void shouldNotCompleteRestorationIfTaskCannotCompleteRestoration() {`
`2929`	`2929`	`verify(stateUpdater).add(task00);`
`2930`	`2930`	`verify(tasks, never()).addTask(task00);`
`2931`	`2931`	`verify(consumer, never()).resume(task00.inputPartitions());`
	`2932`	`+ verifyNoInteractions(consumer);`
`2932`	`2933`	`}`
`2933`	`2934`
`2934`	`2935`	`@Test`