Spring Cloud Stream Test Binder 不填充主题标题

Question

当从 Spring Cloud Stream 测试活页夹中使用消息时，不会填充以下标头：

kafka_receivedTopic

但是当我连接到一个实际的 kafka 代理时，它被填充了。

有没有办法在消费者中获得话题。

我的消费者：

@Bean
public Consumer<Message<PlaneEvent>> planeEventConsumer() {
    return event -> {
        // do something
    };
}

Answer 1

测试活页夹就是这样；它不是“测试 Kafka”活页夹；它是通用的。

通常最好使用真正的 binder 进行测试，使用嵌入式代理或 TestContainers。