spring kafka 单元测试正确姿势

  • 1.引入依赖:
<dependency>
   <groupId>org.springframework.kafka</groupId>
   <artifactId>spring-kafka-test</artifactId>
   <version>3.3.0</version>
   <scope>test</scope>
</dependency>
    1. 使用注解 @EmbeddedKafka ,引用依赖包中的kafka server, 注意配置文件的证书等配置
@SpringBootTest(webEnviroment=SpringBootTest.WebEnviroment.RANDOM_PORT)
@AutoConfigureWebTestClient(timeout="36000")
@EmbeddedKafka(partitions = 1, brokerProperties={ "listeners=PLAINTEXT://localhost:9095" },topics = { KafkaStreamsTests.STREAMING_TOPIC1, KafkaStreamsTests.STREAMING_TOPIC2 })

public class MyApplicationTests {

    @Autowired
    private KafkaTemplate<String, String> template;

    @Test
    public void test() {
        ...
    }

}
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容