ContextConfiguration.java 文件源码

@SuppressWarnings({ "unchecked", "rawtypes" })
@Bean(destroyMethod = "stop")
@Scope(BeanDefinition.SCOPE_PROTOTYPE)
public KafkaMessageConsumer kafkaMessageConsumer(final String topic) {

    return new KafkaMessageConsumer<>(this.kafkaConsumerConfig(), topic, this.senderProvider(), this.messagePublisherProvider());
}