3、消息生产者集成测试：同步发送、异步发送、回调函数、acks与retries配置验证

生产者是消息进入 Kafka 集群的入口，其发送行为的可靠性直接决定下游消费端的数据完整性。本章聚焦生产者集成测试的四个核心维度：同步发送、异步发送、回调函数以及 acks 与 retries 的配置验证。通过可重复的测试用例，验证生产者在正常与异常场景下的行为是否符合预期。

3.1 同步发送与异步发送的测试策略

Kafka 生产者提供两种发送模式，其测试关注点截然不同：

3.2 回调函数集成测试

回调函数是异步发送中捕获结果的标准机制。测试需覆盖以下场景：

• 成功回调：验证 onCompletion(RecordMetadata, null) 中的元数据（分区、偏移量）非空且符合预期。
• 失败回调：验证 onCompletion(null, Exception) 中的异常类型与重试策略一致。
• 顺序保证：同一分区内回调执行顺序与发送顺序一致。
• 线程模型：回调运行在生产者 I/O 线程，测试中不应阻塞回调线程。

// 异步发送 + 回调测试示例
@Test
void testAsyncSendWithCallback() throws Exception {
    CountDownLatch latch = new CountDownLatch(1);
    AtomicReference<RecordMetadata> metaRef = new AtomicReference<>();
    AtomicReference<Exception> exRef = new AtomicReference<>();

    producer.send(new ProducerRecord<>("test-topic", "key", "value"),
        (metadata, exception) -> {
            metaRef.set(metadata);
            exRef.set(exception);
            latch.countDown();
        });

    assertTrue(latch.await(10, TimeUnit.SECONDS));
    assertNull(exRef.get(), "回调不应返回异常");
    assertNotNull(metaRef.get(), "元数据不应为空");
    assertTrue(metaRef.get().offset() >= 0);
}

3.3 acks 配置验证

acks 参数控制生产者等待 Broker 确认的持久化级别。集成测试需验证不同配置下的行为差异：

3.4 retries 与重试行为验证

retries 与 retry.backoff.ms 共同决定生产者的重试策略。集成测试应覆盖：

• 可重试异常：如 LeaderNotAvailableException、NotEnoughReplicasException，验证重试次数耗尽后抛出 TimeoutException。
• 不可重试异常：如 RecordTooLargeException，验证直接抛出且不重试。
• 重试顺序：重试期间消息不会乱序（当 max.in.flight.requests.per.connection=1 时）。

// 重试耗尽测试示例
@Test
void testRetriesExhausted() {
    Properties props = new Properties();
    props.put("retries", 2);
    props.put("retry.backoff.ms", 100);
    props.put("request.timeout.ms", 500);
    // 配置一个不存在的 Broker 地址触发重试

    try (KafkaProducer<String, String> producer = new KafkaProducer<>(props)) {
        producer.send(new ProducerRecord<>("unavailable-topic", "data")).get();
        fail("应抛出 TimeoutException");
    } catch (ExecutionException e) {
        assertTrue(e.getCause() instanceof TimeoutException);
    } catch (Exception e) {
        fail("异常类型不匹配");
    }
}

3.5 生产者发送流程架构图

下图展示生产者从应用线程到 Broker 确认的完整路径，标注了同步/异步分支与 acks/retries 的介入点：

3.6 集成测试用例清单

以下清单覆盖生产者集成测试的核心场景，建议作为 CI 流水线的准入标准：