从SpringKafka2.5之后,可以根据不同的生产者配置拥有多个Kafka模板来看,从文档来看,模板的键类型和值类型不同。
在Spring引导服务中,
是否可能有多个具有相同键和值类型的Spring模板,这些模板仅在它们的生成器配置上有所不同
例如:
KafkaTemplate<String, String> defaultKafkaTemplate
KafkaTemplate<String, String> anotherKafkaTemplate如果答案是对上述问题的肯定:
是否可以为每个模板建立一个单独的模式注册中心?
即
defaultkafkaTemplate与注册表中的模式1相关联,anotherkafkaTemplate与模式10绑定在注册表B中
我能够将单个AWS Glue Schema注册中心与Spring提供的KafkaTemplate集成在一起,我想知道上面的情况是否可能?
发布于 2021-11-22 13:54:25
是的,您可以定义两个bean:
@Bean
KafkaTemplate<String, String> defaultTemplate(ProducerFactory<String, String> pf) {
return new KafkaTemplate<>(pf);
}
@Bean
KafkaTemplate<String, String> otherTemplate(ProducerFactory<String, String> pf) {
return new KafkaTemplate<>(pf, Map.of("some.property", "other.value");
}如果您定义了任何KafkaTemplate bean,那么Boot将不会自动配置一个。
https://stackoverflow.com/questions/70028109
复制相似问题