Merge pull request #15 from ShobhitSingh11/testing-7

Testing 7
ShobhitSingh11 · May 30, 2024 · 9e3eb88 · 9e3eb88
2 parents 682a24e + 84ba9f3
commit 9e3eb88
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java
@@ -28,7 +28,7 @@
 import java.util.Optional;
 import java.util.Set;
 import org.junit.jupiter.api.Test;
-
+//rfrefref
 import static org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.DEFAULT_GENERATION;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;

diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 package org.apache.kafka.clients.consumer;
-
+//rf
 import static org.apache.kafka.clients.consumer.StickyAssignor.serializeTopicPartitionAssignment;
 import static org.apache.kafka.clients.consumer.internals.AbstractStickyAssignor.DEFAULT_GENERATION;
 import static org.junit.jupiter.api.Assertions.assertEquals;

diff --git a/.../java/org/apache/kafka/clients/consumer/internals/CooperativeConsumerCoordinatorTest.java b/.../java/org/apache/kafka/clients/consumer/internals/CooperativeConsumerCoordinatorTest.java
@@ -17,7 +17,7 @@
 package org.apache.kafka.clients.consumer.internals;
 
 import org.apache.kafka.clients.consumer.ConsumerPartitionAssignor;
-
+//erf
 public class CooperativeConsumerCoordinatorTest extends ConsumerCoordinatorTest {
     public CooperativeConsumerCoordinatorTest() {
         super(ConsumerPartitionAssignor.RebalanceProtocol.COOPERATIVE);

diff --git a/...test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutorTest.java b/...test/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutorTest.java
@@ -91,7 +91,7 @@ public void shouldUnassignTaskWhenNotProcessable() {
     @Test
     public void shouldUnassignTaskWhenRequired() throws Exception {
         taskExecutor.start();
-
+        //rf4
         verify(taskManager, timeout(VERIFICATION_TIMEOUT)).assignNextTask(taskExecutor);
         assertNotNull(taskExecutor.currentTask());