test

apache · Jan 14, 2025 · 4e4ed89 · 4e4ed89
1 parent 9bbc792
commit 4e4ed89
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 8 deletions.
diff --git a/...ts/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java b/...ts/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
@@ -59,7 +59,7 @@
 import org.apache.kafka.test.TestUtils;
 
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Tag;
+import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
 
 import java.nio.ByteBuffer;
@@ -1435,8 +1435,8 @@ public void testWakeupAfterJoinGroupReceivedExternalCompletion() throws Exceptio
         awaitFirstHeartbeat(heartbeatReceived);
     }
 
-    @Tag("flaky") // "KAFKA-18310"
-    @Test
+//    @Tag("flaky") // "KAFKA-18310"
+    @RepeatedTest(20)
     public void testWakeupAfterSyncGroupSentExternalCompletion() throws Exception {
         setupCoordinator();
 
@@ -1472,8 +1472,8 @@ public boolean matches(AbstractRequest body) {
         awaitFirstHeartbeat(heartbeatReceived);
     }
 
-    @Tag("flaky") // "KAFKA-18310"
-    @Test
+//    @Tag("flaky") // "KAFKA-18310"
+    @RepeatedTest(20)
     public void testWakeupAfterSyncGroupReceived() throws Exception {
         setupCoordinator();
 
@@ -1506,8 +1506,8 @@ public void testWakeupAfterSyncGroupReceived() throws Exception {
         awaitFirstHeartbeat(heartbeatReceived);
     }
 
-    @Tag("flaky") // KAFKA-15474 and KAFKA-18310
-    @Test
+//    @Tag("flaky") // KAFKA-15474 and KAFKA-18310
+    @RepeatedTest(20)
     public void testWakeupAfterSyncGroupReceivedExternalCompletion() throws Exception {
         setupCoordinator();
 

diff --git a/clients/src/test/resources/log4j2.yaml b/clients/src/test/resources/log4j2.yaml
@@ -31,8 +31,10 @@ Configuration:
       AppenderRef:
         - ref: STDOUT
     Logger:
+      - name: kafka
+        level: DEBUG
       - name: org.apache.kafka
-        level: ERROR
+        level: DEBUG
       # We are testing for a particular INFO log message in CommonNameLoggingTrustManagerFactoryWrapper
       - name: org.apache.kafka.common.security.ssl.CommonNameLoggingTrustManagerFactoryWrapper
         level: INFO