无法启动用于Junit测试的Kafka嵌入式服务器
可能是由于以下原因导致的：
- 依赖问题：检查项目的依赖是否正确配置。确保已经添加了正确的Kafka依赖，以及相关的测试依赖。
- 端口冲突：检查是否有其他进程正在使用Kafka默认的端口。如果是，可以尝试更改Kafka服务器的端口配置。
- 配置问题：检查Kafka服务器的配置文件是否正确。确保配置文件中的相关参数（如Zookeeper连接地址、Kafka监听地址等）正确配置。
- 版本兼容性问题：确保使用的Kafka版本与项目的其他组件（如Kafka客户端、Zookeeper等）版本兼容。
解决这个问题的方法可以包括以下几个步骤：
- 确认依赖：在项目的构建文件（如pom.xml）中添加正确的Kafka依赖。可以参考腾讯云的Kafka产品文档（https://cloud.tencent.com/document/product/597）了解相关依赖信息。
- 检查端口：使用命令行工具（如netstat）检查是否有其他进程正在使用Kafka默认的端口。如果有，可以通过修改Kafka服务器的配置文件（如server.properties）中的
listeners参数来更改端口。 - 配置文件检查：检查Kafka服务器的配置文件（如server.properties）是否正确配置。确保配置文件中的
zookeeper.connect参数指向正确的Zookeeper连接地址，以及listeners参数指定了正确的Kafka监听地址。 - 版本兼容性：确保使用的Kafka版本与项目的其他组件版本兼容。可以参考腾讯云的Kafka产品文档（https://cloud.tencent.com/document/product/597）了解不同版本之间的兼容性信息。
如果以上步骤都没有解决问题，可以尝试以下方法：
- 检查日志：查看Kafka服务器的日志文件，了解具体的错误信息。根据错误信息进行排查和调试。
- 咨询社区：向相关的开发社区或论坛提问，寻求其他开发者的帮助和建议。可以参考腾讯云的开发者社区（https://cloud.tencent.com/developer/community）。
总结起来，无法启动用于Junit测试的Kafka嵌入式服务器可能是由于依赖问题、端口冲突、配置问题、版本兼容性问题等原因导致的。解决这个问题需要检查项目的依赖配置、端口占用情况、Kafka服务器的配置文件、版本兼容性等，并根据具体情况进行调试和排查。
相关·内容
我想在Spring引导应用程序中使用嵌入式Kafka。我可以使用嵌入式卡夫卡进行Junit测试，但是当我尝试在主要应用程序中使用时，嵌入式Kafka对象还没有被识别出来。
当试图加载Spring引导应用程序时，嵌入的kafka对象不是自动加载的。这是用于非测试流的。
@SpringBootApplication
@DirtiesContext
@EmbeddedKafka(topics = "TEST_TOPIC.P2.R2", partitions = 1, controlledShutdown = false, brokerProperties = {
&#
浏览 3提问于2020-01-16得票数 0
我已经构建了一个Springboot应用程序，其中一个依赖项是gRPC服务器。在运行集成测试时，我可以使用TestContainers使用embedded Kafka、embedded MySQL等，但是如何在运行集成测试套件的同时创建嵌入式gRPC服务器？
我有.proto合同定义文件。我会使用Wiremock来模拟对gRPC服务器的请求和响应，但是我还不能启动嵌入式gRPC服务器。
如果我能在这里找到一些帮助，那就太好了。
想想看，我的问题可以概括为在Springboot集成测试中启动一个通用的嵌入式HTTP服务器，使用TestContainers或其他方式。
浏览 0提问于2020-02-26得票数 1
1回答
我有一个弹簧引导应用程序，使用卡夫卡消费者和生产者。卡夫卡的所有配置都在application.yml上
spring:
kafka:
consumer:
enable-auto-commit: true
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializ
浏览 1提问于2020-11-23得票数 1
1回答
我最近更改了我的应用程序的Kafka客户端版本。紧接着，由于下面提到的嵌入式Kafka问题，我的集成测试开始失败。这是我的代码片段，它初始化嵌入式Kafka代理。
@ClassRule
public static EmbeddedKafkaRule kafkaEmbedded = new EmbeddedKafkaRule(1, true, 1, KafkaTopic.getTopics());
在这里，KafkaTopic.getTopics()返回一个主题列表。我目前使用的是spring-kafka-test 2.2.8.RELEASE和spring-kafka 1.3.8.RELEASE
浏览 5提问于2020-05-13得票数 0
1回答
我正在开发一个采用微服务架构的springboot项目，我使用Kafka作为事件总线在其中一些人之间交换数据。我还进行了Junit测试，测试了我的应用程序中不需要总线的部分，以及使用嵌入式Kafka broker来要求总线的其他部分。
我遇到的问题是，当我启动所有测试时，它们花费了这么多时间，而且失败了，因为每个测试都试图连接到嵌入式Kafka broker (连接不可用)，而他们不需要Kafka总线来完成他们的任务。
是否有可能禁用卡夫卡组件的加载这些测试，并只允许他们需要它？
浏览 6提问于2022-07-03得票数 1
我们尝试在应用程序中以编程方式启动kafka服务器(zookeeper和broker)。有什么api /库可以用来做同样的事情吗？
浏览 6提问于2017-09-26得票数 1
1回答
我有以下组件，用于发送消息给经纪人(卡夫卡)，也通过StreamListener的spring-cloud接收。现在我需要写测试，在这里我向嵌入式代理发送消息，并验证消息是否已收到。下面是我的组件：
@Component
public class FooMessaging {
@Autowired
private Processor processor;
public void sendMsg(FooMsg msg) {
// some logic
processor.output().send(MessageBuil
浏览 4提问于2018-09-18得票数 0
我们的Apache拓扑使用KafkaSpout侦听来自Kafka的消息，在进行了大量映射/还原/浓缩/聚合等操作之后，最后将数据插入Cassandra。还有一个kafka输入，我们接收用户查询数据，如果拓扑找到一个响应，然后它发送到第三个kafka主题。现在我们想要使用Junit编写E2E测试，在这个测试中我们可以直接编程地将数据插入到拓扑中，然后通过插入用户查询消息，我们可以在第三点断言在我们的查询上收到的响应是正确的。
为了实现这一点，我们考虑启动EmbeddedKafka和CassandraUnit，然后用它们替换实际的Kafka和Cassandra，然后我们可以在这个单独的Junit测
浏览 2提问于2019-07-12得票数 0
回答已采纳
3回答
我正在使用一个Java应用程序来启动消费者阅读Kafka主题。每次我需要启动使用者应用程序时，我都必须使用cmd中的命令启动和Kafka服务器。是否有可能用小型Java程序启动/阻止它们？谢谢。
浏览 1提问于2017-06-17得票数 3
回答已采纳
1回答
import static org.mockito.Mockito.when;
import java.util.ArrayList;
import org.junit.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.junit.platform.runner.JUnitPlatform;
import org.junit.runner.RunWith;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito
浏览 12提问于2021-04-21得票数 0
我使用嵌入式Kafka测试向Kafka发送消息，当发送失败时，我的代码会自动重新发送，所以我尝试停止嵌入式Kafka，然后在重新发送时重新启动它。但我不知道如何停止和启动嵌入式Kafka。
浏览 5提问于2020-04-03得票数 1
我们需要一个关于如何用ReactiveKafkaConsumerTemplate和ReactiveKafkaProducerTemplate测试embedded-kafka-broker的示例。谢谢。
正确的代码在讨论之后在这里
您可以相应地使用自定义de-serializer来使用自定义ReactiveKafkaConsumerTemplate。
自定义序列化器：
import org.apache.kafka.common.serialization.Serializer;
import com.fasterxml.jackson.core.JsonProcessingException
浏览 4提问于2021-06-23得票数 1
2回答
我正在为junit使用嵌入式Kafka，并且我想为嵌入式Kafka设置状态目录。 我已经尝试设置流配置，但它不工作。
浏览 20提问于2019-06-30得票数 0
1回答
我们使用的是@EmbeddedKafka，在application-test.yml中我们有
kafka:
confluentBootstrapAddress: ${spring.embedded.kafka.brokers}
我可以看到confluentBootstrapAddress是null。
但是，如果在调试模式下选中此选项
this.resolveEmbeddedValue("${spring.embedded.kafka.brokers}") = "127.0.0.1:51020"
然后我可以看到这个值是存在的，并且嵌入式Kafka确实已经启动了
浏览 1提问于2021-03-30得票数 0
我有一个Spring项目运行SpringBoot2.0.2。在单元测试中，我试图启动一个KafkaEmbedded服务器。我知道这个错误。
java.lang.NoClassDefFoundError: org/apache/kafka/common/security/auth/SecurityProtocol
at kafka.utils.TestUtils$.createBrokerConfig(TestUtils.scala:222)
at kafka.utils.TestUtils.createBrokerConfig(TestUtils.scala)
at org.springfr
浏览 2提问于2018-06-06得票数 3
回答已采纳
我正在测试和调试一个运行在kafka之上并使用samza的事件源(或有状态流处理)应用程序。我想删除卡夫卡中的队列和主题，以便samza作业在启动时得到一个空的kafka安装。
我该怎么做？？
编辑：
这个问题比我最初写的要复杂得多，也更具体。
正如大卫所说，从kafka 0.8.2：开始，有一个清除这个话题的解决方案。
我感兴趣的是建立一个测试环境，该环境可以自动加载zookeeper和kafka (它们作为二进制包捆绑在我的git存储库中)。
我正在使用gradle环境+ eclipse和JUnit。我从eclipse运行集成测试(作为JUnit测试)。
如何使装货自动化？我应该创建一个
浏览 3提问于2016-03-17得票数 0
1回答
我最近试图用集成测试和嵌入式Kafka来覆盖我的功能，但在运行它们时遇到了某些问题。结果是一个由KafkaServer抛出的异常。 这是集成测试类： @EmbeddedKafka
@AutoConfigureMockMvc
@Tag("integration")
@ActiveProfiles("test")
@SpringBootTest
public class KafkaHandlerIT {
@Test
@DisplayName("the context initialization tests")
void initCo
浏览 26提问于2020-12-05得票数 0
我使用spring kafka消费来自kafka主题的消息，所以我有一个kafka消费者配置类： @Configuration
class KafkaConfiguration {
// kafka consumer configurations
} 我有一些JUnit测试，会用mockMvc加载spring上下文来测试我的API，我不想测试与kafka消息相关的功能，我如何才能阻止kafka只为JUnit测试消费消息？它总是失败，因为我在本地和CI环境中没有kafka服务器。 Spring profile不是一个很好的选择，因为我必须编写如下代码： @Configuration
@Pro
浏览 115提问于2019-08-29得票数 1
1回答
如何在Spring Boot (2.2+)和Spring Kafka (2.4+)应用程序的@SpringBootTest测试中禁用@KafkaListener实例？ 目标是在特定测试中禁用Kafka侦听器，以便在不启动嵌入式Kafka代理的情况下运行此类测试。
浏览 39提问于2020-01-25得票数 3
回答已采纳
2回答
我正在尝试测试我的Kafka流应用程序。我构建了一个简单的拓扑结构，从输入主题中读取数据，并将相同的数据存储在状态存储中。
我尝试使用TopologyTestDriver为这个拓扑编写单元测试。当我运行测试时，会遇到以下错误。
org.apache.kafka.streams.errors.LockException: stream-thread [main] task [0_0] Failed to lock the state directory for task 0_0
at org.apache.kafka.streams.processor.internals.Abstrac
浏览 7提问于2020-09-22得票数 3
回答已采纳
1回答
我有一个用kafka探索spring的示例项目( find )。我有一个订阅主题my-test-topic-upstream的侦听器，它只会查看消息和键，并将其发布到另一个主题my-test-topic-downstream.我试过，这是当地的卡夫卡( docker-compose文件在那里)，它可以工作。
现在，我打算用嵌入式kafka服务器编写一个测试。在测试中，我有一个嵌入式服务器启动( TestContext.java )，它应该在测试之前启动(重写的junit beforeAll )。
private static EmbeddedKafkaBroker kafka() {
浏览 1提问于2020-03-10得票数 1
回答已采纳
我并在intelliJ IDEA 2018.3中的maven项目中获取此依赖文件
我的pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="ht
浏览 0提问于2019-02-19得票数 1
回答已采纳
2回答
我正在为使用Spark流和Kafka运行的应用程序设置功能测试。要完成的步骤如下
启动动物园管理员服务器
启动kafka服务器
启动消息生成程序，向kafka提供必要的数据
启动火花流应用程序
等5分钟
停止消息产生器
停止火花流应用程序
停止kafka服务器
停止动物园管理员服务器
验证输出
除了简单的bash脚本，其他专业的方法是什么？
我认为这是一个相当普遍的问题，与星火流和卡夫卡无关。也许有一些测试框架支持设置环境、并行运行多个进程和数据验证/断言。
浏览 2提问于2017-02-22得票数 0
回答已采纳
1回答
kafka集成测试用例
、、、、
我对junit测试用例非常陌生，我想为kafka集成编写junit。下面是我的代码
@EnableKafka
@Configuration
public class KafkaConfiguration {
@Value("${bts_config}")
private String bts_config;
@Value("${grpname}")
private String grpname;
@Bean
public ProducerFactory<String, Strin
浏览 8提问于2020-07-30得票数 0
我在我的项目中使用了Kafka和Springboot，现在我有了外部Kafka集群和SpringBoot微服务项目。
使用yml文件，我成功地创建了Kafka生产者和消费者，然后应用程序和kafka就可以很好地通信了。
现在我想在我的sprintboot项目中使用嵌入式kafka。类似于嵌入在Activemq代码之后。
spring:
# Embedded ActiveMQ Configuration Example
activemq:
broker-url: vm://embedded?broker.persistent=false,useShutdownHook=fa
浏览 5提问于2019-01-18得票数 1
5回答
我想使用JUnit测试一个企业java bean (稍后应该部署到JBoss服务器)。但是我不知道我能用什么工具来做这件事。普通的JUnit失败是因为缺少EJB Container和缺少所需的注入。
用谷歌搜索一下，我会找到一个名为JBoss embedded的库，但它似乎已经过时了。我也找不到任何可供下载的源代码或二进制文件。
所以请帮助我们，有什么简单的方法可以在本地生成一个能够在企业bean上运行JUnit测试的“模拟”容器呢？
问候本
浏览 1提问于2010-11-04得票数 3
我正在使用kafka开发一个春季引导中的异步邮件服务器。
我用嵌入式卡夫卡编写了测试，它在一个随机端口中开始了自己的卡夫卡主题，并将其用于测试。
当我启动应用程序时，这个上下文正在加载，它对本地kafka集群的期望。我需要停止应用程序的加载。我从复制了代码，它运行得非常好。当我在我的项目中遵循相同的风格时，我可以看到实际的应用开始了。
SpringKafkaSenderTest .java
package com.mailer.embeddedkafkatests;
import static org.junit.Assert.assertTrue;
import java.util
浏览 0提问于2019-02-05得票数 1
我已经编写了一些JUnit集成测试，这些测试目前从Maven运行(通过命令行或外部CI服务器)。这些集成测试在Maven的“预集成-测试”生命周期阶段自动配置和启动数据库和servlet容器。
我非常希望在Eclipse JUnit启动配置中运行这些JUnit测试(就像我做所有其他测试一样)。但是，JUnit启动配置不会触发预集成测试执行，因此没有正确建立要测试的环境。
让它工作的最好方法是什么？
浏览 7提问于2013-04-15得票数 4
回答已采纳
我有一个简单的弹簧引导控制器，我想为它编写单元测试，但是有一个错误。我搜索了几个小时，但仍然找不到解决方案。这是代码：
HelloController.java
@RestController
public class HelloController {
@Autowired
private HelloService helloService;
@GetMapping("/hello")
public String sayHello(){
return helloService.sayHello();
}
}
Hell
浏览 3提问于2018-01-14得票数 2
回答已采纳
我在启动和运行我的Kafka / confluent spring boot with gradle项目时遇到了一个问题。我最初在这个测试项目中只有一个生产者，一切都运行得很好。然后我添加了一个Kafka消费者，现在我在启动时得到了一个异常。有人能发现这里的问题吗： 首先，这是堆栈跟踪 2021-01-22 19:56:08.566 WARN 61123 --- [ main] ConfigServletWebServerApplicationContext : Exception encountered during context initialization -
浏览 506提问于2021-01-23得票数 0
回答已采纳
1回答
弹簧靴卡夫卡装置失败了
、、、、
在尝试使用spring引导应用程序运行Junit时，我遇到了一个奇怪的问题。它在Kafka服务器启动时抛出致命的错误异常。
这是我的JUnit
import org.junit.ClassRule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springfra
浏览 1提问于2018-02-20得票数 1
您好，我们在tomcat应用服务器上运行了一个spring应用程序。我想在JUnit中添加与Springboot的集成测试。我现在遇到了一个问题，嵌入式tomcat服务器不存储我们的数据源，因此无法查找它……如果服务器配置没有定义数据源，我们的资源中就会有一个应该使用的后备"context.xml“。但是嵌入的tomcat不会读取这个配置，我就是想不出该怎么做。下面是我的JUnit测试中的失败点，因为它在嵌入式tomcat中找不到这个JNDI-Name：
@Bean
public DataSource dataSource()
{
return new JndiDataSource
浏览 1提问于2017-05-09得票数 6
我现在使用的是spring boot 2和JUnit5。我想使用spring-kafka-test进行测试，但是我使用的spring-kafka版本是2.1.8版本。因此我认为不可能使用EmbeddedKafkaBroker，因为它是2.2.x中的东西。 我使用的kafka客户端是1.1.0。我看了一下https://spring.io/projects/spring-kafka中提到的兼容性矩阵，它似乎不适用于client 1.1.0，只是想知道是否有可能只将spring-kafka-test更新到2.2.3版本，以便在Junit 5中使用EmbeddedKafkaBroker，同时仍然使
浏览 26提问于2019-01-24得票数 0
回答已采纳
我在我的应用程序中使用SpringBoot依赖项来使用Kafka。
在我的Kafka实例启动并运行之前，一切都很好，但是问题是我的unit&integration测试，它们在我的本地运行，但在我的部署管道中运行得很好(这很明显，因为应用程序在运行测试时试图连接构建管道中的Kafka实例，却找不到任何)，所以最终得到了以下错误：
[Consumer clientId=consumer-1, groupId=biz-web-group-test] Connection to node -1
could not be established. Broker may not be avail
浏览 2提问于2019-05-16得票数 1
2回答
模拟Tomee服务器属性
、、、
我已经编写了代码，以便可以在不重新启动服务器的情况下更改EntityManagerFactory属性。我使用RESTful jersey服务对其进行了测试。
我是否应该编写junit测试来测试这一点。我还没有写出任何这样的想法，因为服务器必须运行以获取修改后的属性文件。
如果可以做到这一点，我不确定如何模拟服务器。我将非常感谢您的意见。谢谢
浏览 0提问于2016-06-24得票数 0
为了学习Apache Kafka，我开发了一个Spring Boot应用程序，如果我向调用Kafka发送方法的控制器发送POST请求，它会向KafkaTemplate主题发送消息。我正在运行Ubuntu19.04，并在本地成功设置和安装了Kafka和Zookeeper。一切都很好。
当我关闭Zookeeper或Kafka时，问题就出现了。如果我这样做了，那么在启动时，我的应用程序的Kafka AdminClient会定期尝试查找broer，但会将此消息发送到控制台
Connection to node -1 could not be established. Broker may not be
浏览 79提问于2019-07-22得票数 1
回答已采纳
2回答
我正在编写服务器的单元测试。为此，我在Maven中使用Junit。
当我停留在一个地方的时候，怀疑是这样的，
有一个名为WebServer的类，其任务是启动服务器、创建线程池并开始侦听端口上的客户端请求。当我为相同的线程创建一个线程时，在注释@BeforeClass下的Test中，预期它会等待客户机请求，但结果显示测试完成了。
公共类WebServerTest {
@ webserverStarter() {System.out.println(“类前: webserverStarter")；新线程(新WebServer()).start()；} @AfterClass公共静态空洞
浏览 2提问于2013-05-13得票数 0
1回答
我使用EmbededKafka实现了一系列集成测试，以测试一个使用spring框架运行的Kafka应用程序。
流应用程序读取来自Kafka主题的消息，将其存储到内部状态存储中，进行一些转换，并将其发送到另一个微服务以请求主题。当响应返回到响应主题时，它从状态存储中检索原始消息，并根据某些业务逻辑将其转发到我们的下游系统之一，每个下游系统都有自己的主题。
集成测试只是执行业务条件的各种排列。
最初，测试被分成几个类。在运行构建时，来自一个类的测试与另一个类中的测试发生冲突，但有一些冲突异常。我没有花太多时间在这个问题上，只是把所有的测试都移到了同一个类中。这解决了我的问题，所有测试都通过从gra
浏览 3提问于2020-06-16得票数 3
回答已采纳
1回答
有没有办法在JUnit 5中执行"AfterAllTests“操作？例如，关闭与数据库的连接，关闭嵌入式kafka集群等。 附注:有一种方法可以在所有测试之前通过这样的扩展来做一些前置条件： public class BeforeAfterExtension implements BeforeAllCallback, AfterAllCallback {
private static boolean FLAG = Boolean.TRUE;
...
@Override
public void beforeAll(ExtensionContext extensionConte
浏览 10提问于2020-04-15得票数 0
1回答
我有一个简单的Spring应用程序，它从Kafka主题读取并将消息保存到一些缓存中。我想添加一个集成测试，它将启动我的原始应用程序，生成一些来自嵌入式Kafka的消息，然后断言缓存内容。
我在挣扎于“启动我的原始应用程序”部分。如何在Spring集成测试中做到这一点？我试过这样做：
@RunWith(SpringRunner.class)
@SpringBootTest(classes = OriginalApplication.class)
@EmbeddedKafka
public class OriginalApplicationIntegrationTest {
@Test
浏览 1提问于2020-01-08得票数 0
回答已采纳
码定位
我认为可能有许多模块，以使这个问题干净的外观，所以这里是回购。我希望包括所有必要的组成部分。
问题
我正在学习写卡夫卡服务，这个过程包括为生产者和消费者学习单元测试。下面是关于使用使用者设置单元测试的教程。当我运行测试时，我会收到一个类配置错误。
误差
9:34:59.547 [main] WARN kafka.server.BrokerMetadataCheckpoint - No meta.properties file under dir /tmp/kafka-8346130278143417083/meta.properties
09:34:59.567 [main] ERRO
浏览 2提问于2018-02-10得票数 1
回答已采纳
2回答
我需要使用ejb3 beans为类运行junit测试。在我们的例子中，不能仅为此目的而设置jboss，因此我们需要另一种方法来模拟ejb通信。我读到过，使用嵌入式Jboss的EJB3StandaloneBootstrapper应该可以做到这一点，但问题是我无法让它正常工作。
我想知道你们中是否有人知道一个很好的教程，它解释了所有的细节，包括如何配置各种文件(embedded-jboss-beans.xml，ejb3-interceptor-aop.xml等)。随着嵌入式jboss包的出现，junit教程中包含了示例代码，但是，其中的构建脚本失败了。如果你不知道教程，你至少知道我可以在哪里找到嵌
浏览 7提问于2009-03-09得票数 1
我正在寻找关于如何在开发人员&集成测试环境上设置和运行Apache的建议和指导。
我希望避免在每台开发人员的机器上手动下载和设置整个包，并在进行集成测试时找到一种自动启动节点的简单方法。
是否有某种类型的嵌入式Kafka用于开发/集成测试(想一想java开发人员为了避免使用成熟的关系数据库管理系统而使用的H2并行)？
我必须求助于某种无节制的解决方案吗？顺便说一下，我发现了以下有趣的要点：，但它需要设置Vagrant+VirtualBox.
浏览 2提问于2017-03-07得票数 9
回答已采纳
我正在使用一个Spring Boot应用程序，该应用程序是使用Apache Camel spring-xml routes编写的。很少有基于java的应用程序逻辑，它几乎完全是用xml编写的，并且基于各种camel路由。
这些路由配置为使用KAFKA_URL and KAFKA_PORT等属性通过属性文件连接到不同的环境和系统。在其中一个已实现的路由中，应用程序与以下内容连接，并向其消费/生成消息：
<to id="route_id_replaced_for_question" uri="kafka:{{env:KAFKA_URL:{{KAFKA_URL}}}}:
浏览 23提问于2019-10-31得票数 0
回答已采纳
librdkafka c++库有没有一个不需要启动kafka服务器就可以进行单元测试的模拟服务器？如果没有，那么有没有一个轻量级的kafka服务器可以简单易用呢？
librdkafka库中的示例和单元测试是否需要kafka服务器才能运行？如果不是，它使用的是什么？我看到它列出了localhost:9092，它会在启动时启动自己的模拟代理吗？
谢谢!
浏览 0提问于2018-03-02得票数 0
我有一个用Gradle建立的弹簧靴微型服务项目。
在代码签入之后，我想在Jenkins或CI服务器上执行我的黄瓜集成测试。CI服务器上的构建作业在每次代码签入后都会自动触发。这份工作叫我的gradle build.
我能够从我的STS或eclipse中将黄瓜测试用例作为正常的JUnit测试用例来执行，嵌入式tomcat服务器启动后，在它上执行黄瓜测试用例之后，服务器就停止了。
--这正是我在gradle构建中想要的：
如何通过gradle.build ??在运行的spring引导嵌入式服务器上执行黄瓜集成测试。
当前的行为是gradle.build：当CI服务器上调用时，黄瓜集成测试只是在没有
浏览 6提问于2017-11-03得票数 0
我的生产代码运行得很好，但是我的集成测试抛出了SecurityProtocol的ClassNotFoundException。我使用的是spring-boot-parent 1.5.10.RELEASE。
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>1.3.3.RELEASE</version>
浏览 0提问于2018-02-16得票数 6
回答已采纳
我有一些Spring Boot测试，这些测试需要较长的服务器启动时间(我在JUnit中加载一个复杂的域)。我已经将它们放入一个测试套件中，但每次测试都会启动一个新的服务器。
是否可以将它们设置为这样一种方式:服务器只启动一次，每个测试都加载到服务器上并运行，就好像服务器是由测试本身启动的一样？
浏览 16提问于2017-03-17得票数 1
尝试使用neo4j测试服务器时，在构建嵌入式Neo4j服务器时会得到noclassdeffound异常。
private final Neo4j embeddedNeo4jServer = Neo4jBuilders.newInProcessBuilder()
.withDisabledServer()
.withFixture("")
.build(); // exception here
我的pom.xml看起来是这样的：
<dependencies>
<!-- Core Dependenc
浏览 3提问于2022-05-16得票数 0
回答已采纳
我们使用Kafka - Streams test-utils 2.3.0来测试我们的Kafka Streams作业。但是，如果拓扑使用KTable，则无法在Windows上关闭TopologyTestDriver。
在这里，您可以看到一个最小的示例，其中包含一个工作和不工作的测试：
package com.bakdata;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafk
浏览 17提问于2019-07-19得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
