Final try!

codefeedr · Jan 8, 2020 · 406fcb5 · 406fcb5
1 parent d730b1d
commit 406fcb5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/codefeedr-core/src/test/scala/org/codefeedr/stages/kafka/KafkaInputOutputTest.scala b/codefeedr-core/src/test/scala/org/codefeedr/stages/kafka/KafkaInputOutputTest.scala
@@ -97,7 +97,7 @@ class KafkaInputOutputTest
       //the topic configuration will probably be overwritten by the producer
       //TODO check this ^
       println(s"Topic $topic doesn't exist yet, now creating it.")
-      val newTopic = new NewTopic(topic, Optional.of(1), Optional.of(1))
+      val newTopic = new NewTopic(topic, Optional.of(1), Optional.of(1.toShort))
       adminClient
         .createTopics(List(newTopic).asJavaCollection)
         .all()