Как получить MessageListenerContainer с помощью KafkaListenerEndpointRegistry

#spring #spring-boot #apache-kafka #spring-cloud #kafka-consumer-api Вопрос: Я написал код для проверки работоспособности своего пользователя KafkaConsumer вот так: @Component class HealthCheckConsumer : ReactiveHealthIndicator { @Autowired private lateinit var kafkaListenerEndpointRegistry: KafkaListenerEndpointRegistry override…