【发布时间】:2022-12-15 06:50:52
【问题描述】:
我已经编写了以下配置器 bean 并期望被执行,但是 bean 似乎没有被执行,因为当我在内部设置断点时,调试模式下的执行甚至不会停止:
@Bean
fun myStreamsBuilderFactoryBeanConfigurer() =
StreamsBuilderFactoryBeanConfigurer { factoryBean ->
factoryBean.setKafkaStreamsCustomizer { }
factoryBean.streamsConfiguration
}
将 Spring Cloud 2021.0.5 与 Kafka Streams 结合使用。
【问题讨论】:
标签: spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka