Fix missing tests u_u

castorm · May 28, 2020 · ffc7fea · ffc7fea
1 parent 84c2730
commit ffc7fea
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../java/com/github/castorm/kafka/connect/throttle/AdaptableIntervalThrottlerConfigTest.java b/.../java/com/github/castorm/kafka/connect/throttle/AdaptableIntervalThrottlerConfigTest.java
@@ -32,7 +32,7 @@ class AdaptableIntervalThrottlerConfigTest {
 
     @Test
     void whenTailIntervalMillis_thenDefault() {
-        assertThat(config(emptyMap()).getTailThrottler().getIntervalMillis()).isEqualTo(10000L);
+        assertThat(config(emptyMap()).getTailThrottler().getIntervalMillis()).isEqualTo(60000L);
     }
 
     @Test
@@ -42,7 +42,7 @@ void whenTailIntervalMillis_thenInitialized() {
 
     @Test
     void whenCatchupIntervalMillis_thenDefault() {
-        assertThat(config(emptyMap()).getCatchupThrottler().getIntervalMillis()).isEqualTo(1000L);
+        assertThat(config(emptyMap()).getCatchupThrottler().getIntervalMillis()).isEqualTo(30000L);
     }
 
     @Test