馬老師程序員的數(shù)學(xué)
2022-11-16 20:12 作者:666好聽(tīng)的名字 | 我要投稿
@Bean
?public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(
? ? ?ConsumerFactory<String, String> kafkaConsumerFactory, CommonErrorHandler kafkaErrorHandler) {
? ?ConcurrentKafkaListenerContainerFactory<String, String> factory =
? ? ? ?new ConcurrentKafkaListenerContainerFactory<>();
? ?factory.setConsumerFactory(kafkaConsumerFactory);
標(biāo)簽: