程序问答   发布时间:2022-06-01  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了如何获取spring boot默认的Kafka消费者对象大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

如何解决如何获取spring boot默认的Kafka消费者对象?

开发过程中遇到如何获取spring boot默认的Kafka消费者对象的问题如何解决?下面主要结合日常开发的经验,给出你关于如何获取spring boot默认的Kafka消费者对象的解决方法建议,希望对你解决如何获取spring boot默认的Kafka消费者对象有所启发或帮助;

我对 Kafka 消费者的配置在 application.yaml 文件中。我知道如果我只有 1 个消费者,我不需要创建一个 consumerFactory bean,它会在默认情况下由 spring 设置。 我需要测试我的消费者,所以我需要访问我的测试文件中的消费者对象,我不想再次配置它(我想使用 application.yaml 中的默认配置)文件来创建消费者对象。这怎么可能?

解决方法

Spring Boot 为 Spring Kafka 提供了足够全面的自动配置:https://docs.spring.io/spring-boot/docs/2.4.3/reference/html/spring-boot-features.html#boot-features-kafka。

您可以将这组 bean 注入到您的测试类中:

  • KafkaTemplate<?,?> kafkaTemplate
  • ProducerListener<Object,Object> kafkaProducerListener
  • ConsumerFactory<?,?> kafkaConsumerFactory
  • ProducerFactory<?,?> kafkaProducerFactory
  • KafkatransactionManager<?,?> kafkatransactionManager
  • KafkaJaasLoginModuleInitializer kafkaJaasInitializer
  • KafkaAdmin kafkaAdmin
  • ConcurrentKafkaListenerContainerFactoryConfigurer kafkaListenerContainerFactoryConfigurer
  • ConcurrentKafkaListenerContainerFactory<?,?> kafkaListenerContainerFactory
  • KafkaStreamsConfiguration defaultKafkaStreamsConfig
  • KafkaStreamsFactoryBeanConfigurer kafkaStreamsFactoryBeanConfigurer

因此,要在测试中获得 KafkaConsumer,您需要自动装配 ConsumerFactory 并调用其 createConsumer(),您将获得基于配置属性的新实例。

大佬总结

以上是大佬教程为你收集整理的如何获取spring boot默认的Kafka消费者对象全部内容,希望文章能够帮你解决如何获取spring boot默认的Kafka消费者对象所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: