test fixed

katoomba-demo · Jan 15, 2015 · 2cfe0d2 · 2cfe0d2
1 parent a30b2c6
commit 2cfe0d2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/suro-kafka-consumer/src/main/java/com/netflix/suro/input/kafka/KafkaConsumer.java b/suro-kafka-consumer/src/main/java/com/netflix/suro/input/kafka/KafkaConsumer.java
@@ -71,7 +71,7 @@ public String getId() {
 
     private AtomicLong pausedTime = new AtomicLong(0);
 
-    private static final long MAX_PAUSE = 1000;
+    public static long MAX_PAUSE = 1000; // not final for the test
 
     @Override
     public void start() throws Exception {

diff --git a/suro-kafka-consumer/src/test/java/com/netflix/suro/input/kafka/TestKafkaConsumer.java b/suro-kafka-consumer/src/test/java/com/netflix/suro/input/kafka/TestKafkaConsumer.java
@@ -76,6 +76,7 @@ public Object answer(InvocationOnMock invocation) throws Throwable {
 
         properties.setProperty("consumer.timeout.ms", "1000");
         KafkaConsumer consumer = new KafkaConsumer(properties, TOPIC_NAME, numPartitions, router, jsonMapper);
+        KafkaConsumer.MAX_PAUSE = 10000; // for testing
 
         consumer.start();
         latch.await(1000 * 5, TimeUnit.MILLISECONDS);