问题标签 [embedded-kafka]

我有一个为 Kafka 主题生成事件的应用程序代码。所以现在我需要为它编写集成测试。在互联网上搜索后，我对集成测试的定义感到困惑，我应该使用spring-kafka-test库提供的嵌入式 Kafka 服务器还是应该使用我要使用的实际 Kafka 集群来测试我的代码？

这里的集成测试是什么？有人请帮助消除我的困惑。

我的测试是：首先为某个主题生成一条记录，然后无论它是否实际生成都使用它。

我不知道如何使用junit mockito在springboot应用程序中为嵌入式kafka编写测试用例我参考了一些代码并且我使用了它但是KafkaEmbedded KafkaEmbedded 已被弃用

我正在尝试使用 Embedded Kafka 编写集成测试，但我不断收到 NullPointerException。我的测试用例非常简单。它有以下步骤：

1. 读取 JSON 文件并将消息写入 inputTopic。
2. 执行“readStream”操作。
3. 在 Stream 上进行“选择”。这会引发 NullPointerException。

我究竟做错了什么？代码如下：

根据要求.. 这是StackTrace：

我使用 Embedded Kafka 测试向 Kafka 发送消息，当发送失败时，我的代码会自动重新发送，所以我尝试停止 Embedded Kafka，然后在重新发送期间重新启动它。但我不知道如何停止和启动 Embedded Kafka。

我一直在尝试使用 KafkaEmbedded 编写一个简单的 Kafka Listener 单元测试。但是我的听众没有被调用。因为我还需要一个 Avro Serializer/DeSerializer，所以我一直在使用这个链接来获取灵感。

下面是我的测试类的样子。

当我运行这个测试时，我的监听器永远不会被调用。

我在 SpringBootTest 类中使用如下 EmbeddedKafkaRule -

当'container.start();' 执行语句，日志继续打印以下异常-

我试图将默认端口从 0 更改为非零值，但它对以下消息没有帮助 -

我正在使用 org.springframework.kafka:spring-kafka-test:2.5.0.RELEASE 如果您遇到此问题并已解决，请告诉我

谢谢

当我使用此依赖项时：

和

我遇到了这个错误：

试图找出哪个版本的 'scalatest-embedded-kafka' 将适用于 Spark 2.3。

有任何想法吗？

我正在使用fs2-kafka从embedded-kafka读取。

我使用创建嵌入式 kafka withRunningKafkaOnFoundPort，创建主题并发布一些消息。但是，当我尝试使用 fs2-kafka 读回它时，我得到了 NullPointerException。我已经隔离了一个测试用例，代码如下。

这是我的代码：

build.sbt：

这里是堆栈跟踪：

我在 Junits 使用 Embedded Kafka Broker，用于测试我推送到主题的值。

我收到以下错误日志。

我正在比较键键

assertEquals(getKey(), record.getKey());

不知何故，花括号被添加到从 Kafka接收的记录中

任何线索如何解决这个问题，谢谢！

我有一个带有一些 kafka 提供者/消费者和一些集成测试（使用嵌入式 kafka）的 Spring Boot 应用程序。一切正常，直到我将 spring boot 版本提升到 2.3（从 2.1.x）和 spring-kafka 到 2.6.0。

现在我收到以下异常：io.confluent.common.config.ConfigException: Invalid value for configuration schema.registry.ssl.engine.factory.class: Class could not be found.

尝试构建消费者时出现错误。我正在使用一个KafkaAvroDeserializer抱怨MockSchemaRegistryClient上述属性的自定义。

是否有必须设置的属性，或者之前有人遇到过这个问题并有解决方案？

谢谢！