From 57eb296e7bfaee58c4305259487d89c27a171afb Mon Sep 17 00:00:00 2001
From: Pavel Slechta <pavel.slechta@firma.seznam.cz>
Date: Tue, 13 Feb 2018 12:58:30 +0100
Subject: [PATCH] Fix KafkaSourceTest

---
 .../test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sdks/java/extensions/euphoria/euphoria-kafka/src/test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java b/sdks/java/extensions/euphoria/euphoria-kafka/src/test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java
index 913c333b..f9e0d789 100644
--- a/sdks/java/extensions/euphoria/euphoria-kafka/src/test/java/cz/seznam/euphoria/kafka/KafkaSourceTest.java
+++ b/sdks/java/extensions/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) {