Fix KafkaSourceTest

seznam · Feb 13, 2018 · 57eb296 · 57eb296
1 parent fb675a0
commit 57eb296
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...sions/euphoria/euphoria-kafka/src/test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java b/...sions/euphoria/euphoria-kafka/src/test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java
@@ -45,14 +45,14 @@ public void testNoPartitions() {
   public void testPartitions() {
     Node leaderNode = new Node(1, "localhost", 3333);
     PartitionInfo pi = new PartitionInfo("topic", 0, leaderNode, null, null);
-    tryGetPartitions(Collections.emptyList());
+    tryGetPartitions(Collections.singletonList(pi));
   }
 
   @Test(expected = IllegalStateException.class)
   @SuppressWarnings("unchecked")
   public void testNoLeader() {
     PartitionInfo pi = new PartitionInfo("topic", 0, Node.noNode(), null, null);
-    tryGetPartitions(Collections.emptyList());
+    tryGetPartitions(Collections.singletonList(pi));
   }
 
   public void tryGetPartitions(List<PartitionInfo> partitions) {