JUnit Jupiter测试用户创建：是否Mock Kafka及无Mock配置方案

1. 是否应该Mock Kafka？ #

分测试场景判断：

• 单元测试（如测试UserServiceImpl的createUser方法）：必须Mock。单元测试核心是验证当前类的业务逻辑，无需依赖外部服务（Kafka属于外部依赖）。你现在MockUserKafkaProducer的做法完全正确——只需要确认Service层在用户创建成功后，正确调用了生产者的sendMessage方法、传递参数符合预期即可。至于生产者能否真正把消息发到Kafka，属于生产者自身测试或集成测试的范畴。
• 集成测试：不需要Mock，此时要验证完整链路（Service→Producer→Kafka）的正确性，通常用嵌入式Kafka模拟真实环境。

2. 测试Kafka逻辑的最佳实践 #

针对Service层（单元测试） #

• Mock掉UserKafkaProducer这类依赖，重点验证核心业务：用户名查重、用户保存、生产者方法调用。就像你代码里做的那样，用verify(userKafkaProducer, times(1)).sendMessage(user)确认调用次数和参数正确性。
• 如果要验证生产者的消息构造逻辑（比如主题、Payload），应该单独写UserKafkaProducer的单元测试，不要混在Service测试中。

针对Kafka生产者自身（单元测试） #

• MockKafkaTemplate，验证send方法是否被正确调用，消息的主题、Payload、Header是否符合预期。示例代码：

@Test
public void testSendMessage() {
    KafkaTemplate<String, User> mockKafkaTemplate = mock(KafkaTemplate.class);
    UserKafkaProducer producer = new UserKafkaProducer(mockKafkaTemplate);
    
    User testUser = new User();
    testUser.setId("1");
    testUser.setUserName("test_user");
    
    producer.sendMessage(testUser);
    
    // 验证KafkaTemplate的send方法被调用，且消息构造正确
    ArgumentCaptor<Message<User>> messageCaptor = ArgumentCaptor.forClass(Message.class);
    verify(mockKafkaTemplate, times(1)).send(messageCaptor.capture());
    
    Message<User> capturedMessage = messageCaptor.getValue();
    assertEquals(KafkaTopicConfig.MOVIE_SERVICE_USER_TOPIC_NAME, capturedMessage.getHeaders().get(KafkaHeaders.TOPIC));
    assertEquals(testUser.getUserName(), capturedMessage.getPayload().getUserName());
}

集成测试（验证完整链路） #

• 使用Spring Kafka Test提供的@EmbeddedKafka注解启动嵌入式Kafka集群，模拟真实Kafka环境。
• 加载Spring上下文，让KafkaTemplate、UserServiceImpl、UserKafkaProducer都被正确注入，真实发送消息后，通过消费者验证消息是否正确到达。

3. 不Mock Kafka时，KafkaTemplate为null的解决办法 #

如果要做集成测试，避免KafkaTemplate为null，需按以下步骤操作：

1. 引入spring-kafka-test依赖到项目中。
2. 在测试类上添加@SpringBootTest和@EmbeddedKafka注解，让Spring自动配置嵌入式Kafka和KafkaTemplate：

@SpringBootTest
@EmbeddedKafka(partitions = 1, topics = {KafkaTopicConfig.MOVIE_SERVICE_USER_TOPIC_NAME})
public class UserServiceIntegrationTest {

    @Autowired
    private UserServiceImpl userService;

    private User receivedUser;

    // 自定义Kafka消费者，用于接收消息
    @KafkaListener(topics = KafkaTopicConfig.MOVIE_SERVICE_USER_TOPIC_NAME)
    public void receiveMessage(User user) {
        this.receivedUser = user;
    }

    @Test
    public void testCreateUserAndSendKafkaMessage() throws UserNameExistException, InterruptedException {
        UserDTO userDTO = new UserDTO();
        userDTO.setUserName("test_integration_user");

        User savedUser = userService.createUser(userDTO);
        assertNotNull(savedUser);

        // 等待消息被消费
        Thread.sleep(1000);
        assertNotNull(receivedUser);
        assertEquals(savedUser.getUserName(), receivedUser.getUserName());
    }
}

3. 若不想用@SpringBootTest（比如仅测试生产者），可手动配置KafkaTemplate，指定嵌入式Kafka地址：

@EmbeddedKafka
public class UserKafkaProducerIntegrationTest {

    @Autowired
    private EmbeddedKafkaBroker embeddedKafkaBroker;

    @Test
    public void testSendMessageToEmbeddedKafka() {
        // 配置ProducerFactory
        Map<String, Object> producerProps = KafkaTestUtils.producerProps(embeddedKafkaBroker);
        ProducerFactory<String, User> producerFactory = new DefaultKafkaProducerFactory<>(producerProps, new StringSerializer(), new JsonSerializer<>());
        KafkaTemplate<String, User> kafkaTemplate = new KafkaTemplate<>(producerFactory);

        UserKafkaProducer producer = new UserKafkaProducer(kafkaTemplate);
        User testUser = new User();
        testUser.setId("1");
        testUser.setUserName("test");

        producer.sendMessage(testUser);

        // 验证消息是否发送到Kafka
        Consumer<String, User> consumer = KafkaTestUtils.getConsumer(embeddedKafkaBroker);
        consumer.subscribe(Collections.singleton(KafkaTopicConfig.MOVIE_SERVICE_USER_TOPIC_NAME));
        ConsumerRecord<String, User> record = KafkaTestUtils.getSingleRecord(consumer, KafkaTopicConfig.MOVIE_SERVICE_USER_TOPIC_NAME);
        
        assertEquals(testUser.getUserName(), record.value().getUserName());
        consumer.close();
    }
}

内容的提问来源于stack exchange，提问作者Onur Okyay