Debug for CI.

linkedin · Sep 26, 2024 · 1a0fa1f · 1a0fa1f
1 parent 9aeaaf8
commit 1a0fa1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java b/.../src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java
@@ -493,7 +493,7 @@ public void testKafkaConsumerServiceResubscriptionConcurrency() throws Exception
     MetricsRepository mockMetricsRepository = mock(MetricsRepository.class);
     final Sensor mockSensor = mock(Sensor.class);
     doReturn(mockSensor).when(mockMetricsRepository).sensor(anyString(), any());
-    int consumerNum = 6;
+    int consumerNum = 2;
 
     PubSubMessageDeserializer pubSubDeserializer = new PubSubMessageDeserializer(
         new OptimizedKafkaValueSerializer(),