如何使用JUnit5通过testcontainer对kafka运行集成测试

66bbxpm5  于 2021-06-04  发布在  Kafka
关注(0)|答案(3)|浏览(622)

我正试图为我的Kafka消费者编写一个集成测试。
我在用 JUnit 5 ，所以我可以׳无法使用初始化 @Rule ，以及我看到的例子 @Container 初始化它不工作。
我试着把我的junit版本改成 Junit 4 但它会损害我的其他测试（所以我需要继续保持） Junit 5 ).
我试着在JUnit4中使用这个例子：https://www.testcontainers.org/modules/kafka/
还有那些 Junit 5 : https://www.hascode.com/2019/01/using-throwaway-containers-for-integration-testing-with-java-junit-5-and-testcontainers/
但它不认识我的注解( @Testcontainers , @Container ).
gradle进口：

  1. testImplementation 'org.junit.jupiter:junit-jupiter-api:5.4.0'
  2. testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.4.0'
  3. implementation group: 'org.apache.kafka', name: 'kafka-clients', version: '1.1.1'
  4. testIntegrationImplementation "org.testcontainers:kafka:1.11.4"

我正在上载此代码作为注解：

  1. @Testcontainers
  2. public class KafkaTestContainer implements BeforeAllCallback, AfterAllCallback {
  4.     @Container
  5.     public KafkaContainer kafkaContainer = new KafkaContainer();
  6.     private static final Logger logger = LoggerFactory.getLogger(KafkaTestContainer.class);
  8.     @Inject
  9.     private KafkaTestContainer() {
  10.         try {
  12.         } catch (Exception e) {
  13.             logger.error(e.getMessage());
  14.         }
  15.     }
  17.     private String getKafkaBootstrapServers(Request request) throws IOException {
  18.         return this.kafkaContainer.getBootstrapServers();
  19.     }
  21.     public void stopKafkaTestContainer() {
  22.         // Stop the container.
  23.         kafkaContainer.stop();
  25.     }
  27.     @Override
  28.     public void afterAll(ExtensionContext context) throws Exception {
  29.     }
  31.     @Override
  32.     public void beforeAll(ExtensionContext context) throws Exception {
  33.         boolean isKafkaRunning = this.kafkaContainer.isRunning();
  34.         if(isKafkaRunning) {
  35.             logger.info("start Kafka docker!!");
  36.         }
  37.     }

iskafkarunning值始终为false。
感谢您对kafka测试容器初始化的任何帮助？
我错过了什么？？

Javaapache-kafkatestcontainersintegration-testingjunit5

3条答案

按热度按时间
5t7ly7z5

5t7ly7z51#

缺少以下依赖项：

  1. <dependency>
  2.     <groupId>org.testcontainers</groupId>
  3.     <artifactId>junit-jupiter</artifactId>
  4.     <version>1.13.0</version>
  5.     <scope>test</scope>
  6. </dependency>
赞(0）分享  回复(0）举报  2021-06-05
jckbn6z7

jckbn6z72#

当然有更复杂的方法可以做到这一点，但我认为你只需要：

  1. @Override
  2.     public void beforeAll(ExtensionContext context) throws Exception {
  3.         while(!this.kafkaContainer.isRunning());
  4.         logger.info("start Kafka docker!!");
  5.     }

如果可以的话，您应该在混合中添加一个真正的异步框架，并实现更成熟的重试和超时。

赞(0）分享  回复(0）举报  2021-06-05
bfhwhh0e

bfhwhh0e3#

以下是我的设置：

  1. ...
  2. <properties>
  3.         <java.version>1.8</java.version>
  4.         <testcontainers.version>1.14.3</testcontainers.version>
  5.         <junit.jupiter.version>5.6.2</junit.jupiter.version>
  6.         <lettuce.version>5.3.3.RELEASE</lettuce.version>
  7.         <lombok.version>1.18.12</lombok.version>
  8.     </properties>
  10.     <dependencies>
  11.         <dependency>
  12.             <groupId>org.springframework.boot</groupId>
  13.             <artifactId>spring-boot-starter-data-redis</artifactId>
  14.         </dependency>
  15.         <dependency>
  16.             <groupId>org.springframework.security</groupId>
  17.             <artifactId>spring-security-messaging</artifactId>
  18.         </dependency>
  19.         <dependency>
  20.             <groupId>io.lettuce</groupId>
  21.             <artifactId>lettuce-core</artifactId>
  22.             <version>${lettuce.version}</version>
  23.         </dependency>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-web</artifactId>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.kafka</groupId>
  30.             <artifactId>spring-kafka</artifactId>
  31.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-devtools</artifactId>
  35.             <scope>runtime</scope>
  36.             <optional>true</optional>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>org.projectlombok</groupId>
  40.             <artifactId>lombok</artifactId>
  41.             <version>${lombok.version}</version>
  42.             <optional>true</optional>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-test</artifactId>
  47.             <scope>test</scope>
  48.             <exclusions>
  49.                 <exclusion>
  50.                     <groupId>org.junit.vintage</groupId>
  51.                     <artifactId>junit-vintage-engine</artifactId>
  52.                 </exclusion>
  53.             </exclusions>
  54.         </dependency>
  55.         <dependency>
  56.             <groupId>org.springframework.kafka</groupId>
  57.             <artifactId>spring-kafka-test</artifactId>
  58.             <scope>test</scope>
  59.         </dependency>
  61.         <!-- JUnit 5 dependencies -->
  62.         <dependency>
  63.             <groupId>org.junit.jupiter</groupId>
  64.             <artifactId>junit-jupiter-api</artifactId>
  65.             <version>${junit.jupiter.version}</version>
  66.             <scope>test</scope>
  67.         </dependency>
  68.         <dependency>
  69.             <groupId>org.junit.jupiter</groupId>
  70.             <artifactId>junit-jupiter-params</artifactId>
  71.             <version>${junit.jupiter.version}</version>
  72.             <scope>test</scope>
  73.         </dependency>
  74.         <dependency>
  75.             <groupId>org.junit.jupiter</groupId>
  76.             <artifactId>junit-jupiter-engine</artifactId>
  77.             <version>${junit.jupiter.version}</version>
  78.             <scope>test</scope>
  79.         </dependency>
  81.         <!-- Testcontainers dependencies -->
  82.         <dependency>
  83.             <groupId>org.testcontainers</groupId>
  84.             <artifactId>testcontainers</artifactId>
  85.             <version>${testcontainers.version}</version>
  86.             <scope>test</scope>
  87.         </dependency>
  88.         <dependency>
  89.             <groupId>org.testcontainers</groupId>
  90.             <artifactId>junit-jupiter</artifactId>
  91.             <version>${testcontainers.version}</version>
  92.             <scope>test</scope>
  93.         </dependency>
  94.         <dependency>
  95.             <groupId>org.testcontainers</groupId>
  96.             <artifactId>kafka</artifactId>
  97.             <version>${testcontainers.version}</version>
  98.             <scope>test</scope>
  99.         </dependency>
  100.     </dependencies>

测试等级exmaple：

  1. @SpringBootTest
  2. @Testcontainers
  3. class KafkaProducerTest {
  5.     @Container
  6.     public KafkaContainer container = new KafkaContainer();
  8.     @Test
  9.     void sendMessage() {
  10.         assertTrue(container.isRunning());
  11.     }
  12. }
展开查看全部
赞(0）分享  回复(0）举报  2021-06-04
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com