我应该测试我的代码，通过嵌入的'withrunningkafka'使用kafka服务器的所有消息，如下所示：https://github.com/manub/scalatest-embedded-kafka
我尝试通过创建的嵌入式生产者向主题发送消息。
我尝试通过我在项目中的代码来使用生成的消息（由嵌入式生产者创建）。
“与定制生产商和消费者进行测试”应{

"work" in {

    withRunningKafka {

      1. val producer: KafkaProducer[String, String] =
               aKafkaProducer[String](valueSerializer, config)

         val topic = "topic-to-test"

         producer.send(new ProducerRecord[String, String](topic, "some message 1"))
         producer.send(new ProducerRecord[String, String](topic, "some message 2"))
         producer.close()

      2. val ok: Future[Done] = Consumer
        .committableSource(
            consumerSettings,
            Subscriptions.topics(topic))
        .map(msg => println(msg.record.value()))
        .runWith(Sink.ignore)

       ok should be (Done)
    }
}}

问题就在这里：“ok”不会给出“done”的结果。一般来说，我测试消费者的逻辑正确吗？