我正在尝试检查testcontainers作为集成测试的流水线，但我不知道如何获得bootstrapServers，至少在最新的testcontainers版本中，并在那里创建一个特定的主题。如何使用'containerDef‘来提取引导服务器并添加主题？ import com.dimafeng.testcontainers."spark-sql-kafka-0-10" % "3.0.3" % Compil
浏览 38提问于2021-08-24得票数 4
回答已采纳
1回答
我正在尝试为debezium集成设置一个集成测试环境(遵循此中的说明)，但测试容器(默认镜像: confluentinc/cp-kafka:5.2.1)无法启动，而是抛出异常。我使用下面提到的代码来创建KafkaContainer bean public KafkaContainer kafkaContainer() {
jar:file:/home&#x
浏览 0提问于2020-09-09得票数 0
SpringBoot2.6.5修复了这个问题(参见)
自从升级到SpringBoot2.6.X(在我的例子中是2.6.1)之后，我有多个项目出现了失败的单元--在EmbeddedKafka上无法启动的测试，这些测试都是在Linux上运行的。16:15:00.300 INFO 13864 --- [ main] k.utils.Log4jControllerRegistration$ : Registered kafkasun.nio.fs.WindowsException.rethrowAsIOExceptio
浏览 44提问于2021-12-09得票数 12
回答已采纳
我有一个函数，它接受Kafka streams的一个实例，获取状态存储，解析它并进行一些计算。.} 让我们假设Kafka如何测试这些需要Kafka设置的函数？
浏览 24提问于2020-10-09得票数 0
2回答
我想测试一下。
使用内嵌的kafka测试与使用测试容器的测试有哪些缺点？我很熟悉测试容器，它提供了完整的功能卡夫卡。与容器相比，嵌入式kafka有哪些局限性？(具体示例请参阅)
浏览 5提问于2021-03-29得票数 4
回答已采纳
测试无法用错误的Cannot resolve method 'parse' in 'DockerImageName'编译@Testcontainers testImplementation 'com.google.guava:guava:23.0'
testImplementation 'org.testcontainers
浏览 7提问于2020-10-17得票数 1
回答已采纳
我希望从配置中为TestContainers Kafka映像指定一个自定义端口，以便以后能够重新使用引导服务器param进行黑匣子应用程序测试，使用 Kafka模块没有找到用于在运行容器时修复端口的APIwith Matchers {
import org.testcontainers.Testcontainers<
浏览 6提问于2022-05-16得票数 1
1回答
我想为Scala项目设置一个测试环境。此外，我需要启动Kafka，它在docker容器中运行。在测试开始之前，应该先启动Kafka容器。我正在使用Scalatest，并考虑在测试运行之前在TestFixture中启动Kafka容器。 问题是，在运行测试之前，推荐使用哪种方式启动容器。
浏览 17提问于2019-05-12得票数 3
回答已采纳
我想启动kafka测试容器并获取它的引导服务器：@ContextConfiguration(classes = {TestConfig.class, MyApplication.class}, initializers = MyIntegrationTest.Initializer.class)public class MyIntegrationTest=" + KAFKA.getBootstrapServers(),
&
浏览 13提问于2019-10-22得票数 2
回答已采纳
我编写了一个集成测试，以显示发送给Kafka的消息将与侦听器一起到达。只有当我使用KAFKA_PORT=9092时，它才会通过。该常量是开发人员机器(或CI机器)上使用的端口。最后，我想在动态分配的端口(即使用GenericContainer而不是FixedHostPortGenericContainer)上完成这一任务，但目前我只想能够使用不同的端口。如果我在下面的代码中设置了KAFKA_PORT=59092，那么测试就失败了，并且
浏览 3提问于2020-06-08得票数 2
回答已采纳
3回答
我正试图为我的卡夫卡消费者编写一个集成测试。以及Junit 5：上的那些
但是它不识别我的注释(@Testcontainers，@Container)。', name: 'ka
浏览 1提问于2019-08-15得票数 3
我正在尝试在TestContainers中启动一个kafka容器。;public class FirstTest {我能够成功地启动redis和postgres容器。这是我使用的kafkaContainer版本： <dependency>
<groupId>org.testco
浏览 134提问于2020-10-22得票数 0
1回答
如何设置一个单元测试环境，在这个环境中我可以创建Kafka主题，使用FlinkKafkaProducer对它们进行写入，并使用FlinkKafkaConsumer对它们进行读取？server.createTestTopic("my.test.topic", 1, 1)
server.shutdown() 但是这会抛出一个错误java.lang.NoClassDefFoundError: kafka
浏览 5提问于2020-08-03得票数 0
回答已采纳
我使用spring kafka消费来自kafka主题的消息，所以我有一个kafka消费者配置类： @Configuration // kafkaconsumer configurations
} 我有一些JUnit测试，会用mockMvc加载spring上下文来测试我的API，我不想测试与kafka消息相关的功能，我如何才能阻止kafka只为
浏览 115提问于2019-08-29得票数 1
当我试图为Kafka容器编写集成测试时，我在构建项目之后得到了这个错误。我不知道出了什么问题。22:46:01.464 [Thread-4] WARN o.t.utility.ResourceReaper - Unable to delete image testcontainers/byvren8fgzpzaxgycom.github.dockerjava.api.exception.NotFoundException: Status 404: {"message":"No such image:
浏览 10提问于2021-02-18得票数 0
回答已采纳
我有两个Spring Boot应用程序，一个是Kafka publisher，另一个是consumer。我正在尝试编写一个集成测试，以确保事件被发送和接收。当在集成开发环境中运行或者在没有其他测试的情况下从命令行运行时，测试是绿色的，比如mvn test -Dtest=KafkaPublisherTest。然而，当我构建整个项目时，org.awaitility.core.ConditionTimeoutException测试失败了。项目中有多个@EmbeddedKafka测试</
浏览 18提问于2021-11-28得票数 0
我在本地测试设置中使用Kafka testcontainers镜像。 我想更新Kafka的配置以匹配我的部署环境。
浏览 16提问于2021-01-07得票数 0
回答已采纳
1回答
我在Kafka中使用TestContainers，但我的测试中使用的是come缓存。我已经构建了Hello World Kafka Stream应用程序，在我的测试中，我得到了答案： Flat Map: Hello World!Grouping: key=null work=helloKey=hello value=7 我的测试非常简单，我创建KafkaContainer/cp-<
浏览 39提问于2021-04-20得票数 2
回答已采纳
Testcontainers可以管理坞化服务依赖项，比如数据库、Kafka、Elasticsearch等等，用于集成测试。
我能否在本地开发期间配置我的Spring应用程序来管理这些服务依赖项？我想将它与Testcontainers集成起来，以便不仅在测试执行期间，而且在本地开发期间，在应用程序启动时，用MySQL提供一个Docker容器。
浏览 9提问于2022-02-20得票数 -2
回答已采纳
有人知道如何使用testContainers 创建用于集成测试的apache-spark集群吗？
任何运行的例子，请，我正在努力找到它。
浏览 0提问于2019-12-09得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
