Отсутствует bean-компонент zipkin2.reporter.Sender при использовании `@AutoConfigureAfter (TraceAutoConfiguration.class)` - PullRequest
Новая
       93

Отсутствует bean-компонент zipkin2.reporter.Sender при использовании `@AutoConfigureAfter (TraceAutoConfiguration.class)`

0 голосов
/ 24 сентября 2018

TLDR:

  • Репро проект здесь: https://github.com/snussbaumer/zipkin-app-wont-start-repo
  • Я хочу использовать Zipkin Kafka Sender
  • Мне также нужен фрагмент автоконфигурации для запускапосле TraceAutoConfiguration из Sleuth
  • Если я использую @AutoConfigureAfter, приложение не запускается и завершается с сообщением No qualifying bean of type 'zipkin2.reporter.Sender' available

Подробнее:

Я пытаюсь создать собственный сервис инструментов Sleuth, который также может работать, когда нет трассировки.Вот действительно упрощенная версия интерфейса службы: 

public interface SomeService {
    String decorate(String value);
}

Затем я создаю автоконфигурацию (так как этот код находится в отдельном модуле, используемом во многих проектах): 

@Configuration
@AutoConfigureAfter(name = "org.springframework.cloud.sleuth.autoconfig.TraceAutoConfiguration")
@Slf4j
public class TestAutoConfiguration {

    @ConditionalOnBean(type = "brave.Tracer")
    @Configuration
    public static class TracedConfiguration {

        @Bean
        public SomeService someService(Tracer tracer) {
            log.info("Create traced SomeService");
            return value -> value + " [" + tracer.currentSpan().toString() + "]";
        }
    }

    @ConditionalOnMissingBean(type = "brave.Tracer")
    @Configuration
    public static class NoTracedConfiguration {

        @Bean
        public SomeService someService() {
            log.info("Create not traced SomeService");
            return value -> value + " [not-traced]";
        }
    }
}

Идея заключается в том, чтобы иметь своего рода Noop-версию сервиса, когда Tracer недоступен.

Затем я объявляю автоконфигурацию в файле spring.factories как обычно.

Этоприложение, которое я хочу запустить: 

@SpringBootApplication
@RestController
@Slf4j
public class ReproApplication {

    @Autowired
    private SomeService someService;

    @GetMapping("/test")
    public String test() {
        log.info("Test Endpoint called, check TraceId/SpanId/ParentSpanId in log");
        return someService.decorate("hello world") + "\n";
    }

    public static void main(String[] args) {
        SpringApplication.run(ReproApplication.class, args);
    }

}

Для всего этого я хочу использовать Zipkin с KafkaSpanReporter.Поэтому мои application.properties выглядят так: 

spring.application.name=repro
server.port=8080
spring.kafka.bootstrapServers=kafka:9092
spring.sleuth.sampler.probability=1.0
spring.zipkin.sender.type=kafka
logging.level.org.springframework.boot.autoconfigure=DEBUG

и мой (усеченный) pom.xml примерно так: 

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-kafka</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
  </dependency>
  <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.16.20</version>
  </dependency>
</dependencies>

Когда я пытаюсь запустить этот код, я получаю ошибку:

No qualifying bean of type 'zipkin2.reporter.Sender' available: expected at least 1 bean which qualifies as autowire candidate. Dependency annotations: {}

Если я посмотрю отчет о конфигурации, то увижу: 

Parameter 2 of method reporter in org.springframework.cloud.sleuth.zipkin2.ZipkinAutoConfiguration required a bean of type 'zipkin2.reporter.Sender' that could not be found.
    - Bean method 'kafkaSender' not loaded because @ConditionalOnBean (types: org.springframework.boot.autoconfigure.kafka.KafkaProperties; SearchStrategy: all) did not find any beans of type org.springframework.boot.autoconfigure.kafka.KafkaProperties

Это странно, потому что есть @EnableConfigurationProperties(KafkaProperties.class) на KafkaAutoConfiguration и отчет о конфигурации ясно показывает:

KafkaAutoConfiguration matched:
  - @ConditionalOnClass found required class 'org.springframework.kafka.core.KafkaTemplate'; @ConditionalOnMissingClass did not find unwanted class (OnClassCondition)

Еще более странно то, что если я удаляю @AutoConfigureAfter(name = "org.springframework.cloud.sleuth.autoconfig.TraceAutoConfiguration") в моей автоконфигурации, служба запускается нормально =>, но я получаю аромат NoTracedConfiguration моего компонента, поэтому Tracerвероятно, еще не настроен.

Что я могу сделать, чтобы решить эту проблему?

1 Ответ

0 голосов
/ 25 сентября 2018

Наконец-то он заработал, удалив @AutoConfigureAfter, @CondtionnalOnBean и @ConditionnalOnMissingBean, используя вместо него @ConditionalOnClass, @ConditionnalOnMissingClass и воспроизведя другие @Conditionnals из TraceAutoConfiguration.Не отлично, но, по крайней мере, работает.

...