使用spring-kafka-test中的@EmbeddedKafka测试监听器

问题描述

我正在尝试在使用@KafkaListener创建的springboot中测试侦听器 但是侦听器始终在localhost：9092上侦听，而不是使用此embededKafka

我的听众是这样的：

@Component
@Slf4j
class SomeListener {
    private final List<String> receivedMessages = new ArrayList<>();

    @KafkaListener(topics = "some-ultra-cool-topic")
    public void onKafkaMessage(String theMessage) {
        log.info("Message received {}",theMessage);
        receivedMessages.add(theMessage);
    }

    Collection<String> getAll() {
        return unmodifiableCollection(receivedMessages);
    }
}

然后像这样进行spock测试：

@SpringBootTest
@EmbeddedKafka
@TestPropertySource(properties = ['spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}','spring.kafka.consumer.auto-offset-reset=earliest'])
class SomeListenerTest extends Specification {
    @Autowired
    EmbeddedKafkaBroker embeddedKafkaBroker

    @Autowired
    SomeListener someListener

    void 'should receive message'() {
        given:
            def sender = new KafkaTemplate<>(new DefaultKafkaProducerFactory<String,String>(KafkaTestUtils.producerProps(embeddedKafkaBroker)))

        when:
            sender.send('some-ultra-cool-topic','first message content')
        then:
            someListener.all.size() == 1
    }

}

我的application.yaml没有配置引导服务器-因此，它完全是spring-boot的默认设置。

我在日志中看到生产者正在向代理发送消息（它每次都在不同的随机端口上启动）。 但是侦听器总是尝试连接到本地主机上的代理：9092

如何配置它以使用此嵌入式产品？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）