Hystrix Stream с использованием потоковой кафки - PullRequest
Новая
       37

Hystrix Stream с использованием потоковой кафки

0 голосов
/ 10 июня 2019

Я пытаюсь контролировать автоматический выключатель, используя kafka в качестве MQ-сервера и Turbine. 

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</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-netflix-hystrix-stream</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-logging</artifactId>
            </exclusion>
        </exclusions>
</dependency>

Я хочу перенести показатели, собранные в Hystrix, в собственную тему. Но приложение всегда отправляет сообщение в тему, называемую «hystrixStreamOutput». хотя я установил autoCreateTopic = false 

spring.cloud.stream.kafka.binder.autoCreateTopics=false
spring.cloud.stream.kafka.binder.brokers= machine1:9092,machine2:9092,machine3:9092
spring.cloud.stream.kafka.binder.auto-create-topics=false

Тема "hystrixStreamOutput" по-прежнему создается автоматически.

Как я могу использовать другую тему для передачи метрик из Hystrix и игнорирования автоматического создания темы?

Спасибо!

...