问题标签 [spring-kafka-test]

我们有一个带有 spring-kafka 的 spring boot 应用程序，我们正在使用嵌入式 kafka 进行测试。我们已将 Spring boot 升级到 2.3.1 版本，并遵循最新的 spring kafka 依赖项，即 2.5.2。现在我们在执行测试时遇到了错误。我检查了zookeeper-jute依赖项存在于zookeeper-3.5.7中。

当我在我们的 pom 中添加zookeeper-jute依赖项时，它工作正常

我正在编写 Junit 测试用例，我想模拟 KafkaTemplate 方法kafkaTemplate.send(TOPIC_NAME, "someData");。在我的项目中，我使用的是 Spring Boot 和 Kafka。

下面是StudentRecords课堂。我mockito用于模拟依赖项。

测试类如下：

我收到以下错误

它正在线上发生studentRec.sendStudentData(studentDTO);

我如何为此解决/编写junit？

将junit更新到以上一个后，在此语句中出现以下错误Mockito.verify(kafkaTemplate).send(Mockito.anyString(), Mockito.anyString());

我对 junit 测试用例很陌生，我想为 kafka 集成编写 junit。下面是我的代码

在其他课程中，我有一种方法可以使用 kafkaTemplate 将消息发送到 kafka

现在我想为方法编写测试用例KafkaConfig (@EnableKafka, @Configuration)和测试用例public void sendDataToKafka(String topicName, String msg)

我是编写junit测试用例的新手，有人可以帮我吗

我有一个使用@KafkaListener注释的 Kafka 消费者。要使用嵌入式 Kafka 服务器编写测试用例，我遵循此处的代码：如何为 @KafkaListener 编写单元测试？. 示例代码中建议的方法不起作用。我的代码中唯一的区别是该值不是字符串。所以我相应地配置了 producerFactory JsonSerializer。

引导应用程序的类是：

Kafka监听器代码如下：

当我运行时mvn test，我在控制台中看到如下错误：

每次我运行代码时，container.stop()都会因 NullPointerException 而失败。我该如何解决这个问题？我错过了什么吗？

我已经更新了一个项目的库，特别是我已经将 Spring Boot 从版本 2.2.6 更新到了 2.3.2。

如迁移文档中所述，这也意味着我的 Kafka 依赖项发生了变化，升级到 Spring Kafka 和 Kafka 2.5

但是，由于这种变化，我的一些测试“随机”失败，例如，当我执行所有测试时，我在其中一些测试中遇到了这种失败（但并不总是在相同的测试中）：

来自这个特定的行：

文档中没有提及为什么会发生这种情况，也没有其他日志错误消息可以说明为什么会发生这种情况。由于我没有改变我的应用程序的逻辑，我是否在迁移过程中遗漏了一些东西？

如果我尝试这样的事情：

为了只得到第一个，以前工作的测试会IndexOutOfBoundsException因索引而失败。

我正在尝试在使用 @KafkaListener 创建的 springboot 中测试侦听器但侦听器总是在 localhost:9092 上侦听，而不是使用这个 embededKafka

我的听众看起来像这样：

像这样的 spock 测试：

我的 application.yaml 没有配置引导服务器 - 所以它是 spring-boot 的完全默认设置。

我可以在日志中看到生产者正在向代理发送消息（它每次都在不同的随机端口上启动）。但是侦听器总是尝试连接到 localhost:9092 上的代理

如何配置它以使用这个嵌入式？

我构建了一个 Spring Boot 应用程序来在 Kafka 中生成数据，但现在我需要将此应用程序连接到旧的 Kafka (0.11v)。我尝试只更改引导服务器，但收到连接错误。

我仔细检查了这个 Kafka 实例是否正常工作，以及其他应用程序是否正在连接。

我的问题是，像 v2.5.4.RELEASE 这样的新版本 spring-Kafka 是否可以连接到旧版本的 Kafka。我可以添加任何配置来使用旧版 Kafka 实例吗？我构建了一个 Spring Boot 应用程序来在 Kafka 中生成数据，但现在我需要将此应用程序连接到旧的 Kafka (0.11v)。我尝试只更改引导服务器，但收到连接错误。

我仔细检查了这个 Kafka 实例是否正常工作，以及其他应用程序是否正在连接。

我的问题是，像 v2.5.4.RELEASE 这样的新版本 spring-Kafka 是否可以连接到旧版本的 Kafka。我可以添加任何配置来使用旧版 Kafka 实例吗？

使用@EmbeddedKafka(topics = { "checkins" }) 时出现错误

我正在使用弹簧靴 2.3.3.RELEASE

我的毕业典礼看起来像

我正在使用 spring kafka 来实现具有默认属性的 kafka 侦听器。我注意到有一些失败，例如：代理不可用或消费消息后任何内部调用失败，它会停止消费消息，并且在提交之前消费的消息时我可以看到附加错误。

我们如何让我们的 kafka 消费者重新连接到组并开始消费消息，而无需在 kubernetes 中重新启动 pod？目前，当我们重新启动我们的 kubernetes pod 时，kafka 消费者开始收听来自上次提交的偏移量的消息。

我创建了一个简单的测试用例来启动我的 Spring Kafka 测试。我正在使用 Spring-Kafka 版本 2.5.6.RELEASE 和 Junit5。我跟着文档here。

我收到以下错误：

我该如何解决这个问题？