Error Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic:

[ziboumima]

Hi, first thanks for the work to bring a way to test kafka easily
I'm using this package but I failed to make the simple test

package com.the_ica.cli
import info.batey.kafka.unit.{ KafkaUnit, KafkaUnitRule }
import kafka.producer.KeyedMessage


object KafkaTest {
  def main(args: Array[String]): Unit = {
    val kafkaUnitServer = new KafkaUnit(2181, 9092)
    val testTopic = "topic"
    kafkaUnitServer.startup()
    kafkaUnitServer.createTopic(testTopic)
    val keyedMessage = new KeyedMessage(testTopic, "key", "value")
    kafkaUnitServer.sendMessages(keyedMessage)
    val results = kafkaUnitServer.readMessages(testTopic, 1)
    println(results)
  }
}

The full error is

Created topic "topic".
ERROR - k.p.a.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: topic
ERROR - k.n.Processor - Closing socket for /127.0.0.1 because of error