自定义流生成器工厂BeanConfigurer不会被拾取

Question

我已经编写了以下配置器bean并期望执行，但是bean似乎没有被执行，因为在调试模式下执行甚至在我在内部设置断点时也没有停止:

@Bean
fun myStreamsBuilderFactoryBeanConfigurer() =
StreamsBuilderFactoryBeanConfigurer { factoryBean ->
factoryBean.setKafkaStreamsCustomizer { }
factoryBean.streamsConfiguration
}

使用Spring Cloud 2021.0.5 with Kafka Streams.

Answer 1

不知道发生了什么。下面是我们在测试中使用的StreamsBuilderFactoryBeanConfigurer。如果配置器不工作，该测试应该失败。请看看这个断言。

如果事情仍然失败，请创建一个非常小的Java示例，我们可以进一步调试。