apache-kafka - 使用带有 Schema Registry 的 Scala 对 EmbeddedKafka 进行单元测试

Question

我需要在 Spark 应用程序中使用嵌入式 Kafka 对我们的 Kafka 应用程序进行单元测试。

EmbeddedKafka 有许多使用 java SpringBoot 或使用 Kafka Streams 的示例，但未能为使用 Scala 的 EmbeddedKafka 获得一些好的参考。

我尝试了下面的代码作为开始，但以我有限的知识无法进一步进行。

import io.github.embeddedkafka.EmbeddedKafka
import org.scalatest.matchers.should.Matchers
import org.scalatest.wordspec.AnyWordSpecLike

class KafkaTest extends AnyWordSpecLike with Matchers 
{

"work" in {
EmbeddedKafka.start()

// Some code to assert

EmbeddedKafka.stop()

}

如果有人分享他们的知识或 Url 关于使用 Scala 和模式注册表使用嵌入式 kafka 的知识，这真的很有帮助吗？