Как я могу отключить весенний облачный поток для целей разработки, если не запущен брокер kafka? - PullRequest
Новая
       30

Как я могу отключить весенний облачный поток для целей разработки, если не запущен брокер kafka?

0 голосов
/ 28 января 2020

У меня есть несколько приложений весенней загрузки, реализующих Spring Cloud Stream с брокерами Kafka. Я хотел бы знать, могу ли я остановить или отключить весенний облачный поток или соединения с брокером kafka, чтобы запустить приложения.

Ответы [ 2 ]

0 голосов
/ 30 января 2020

Приложения должны запускаться, даже если посредники недоступны.

Вы можете добавить связыватель oop в classpath и сделать его связующим по умолчанию или указать его для привязки. Вот некоторый код с Kotlin:

Класс реализации NoOpBinder: 

package com.demo

import org.slf4j.LoggerFactory
import org.springframework.cloud.stream.binder.Binder
import org.springframework.cloud.stream.binder.Binding
import org.springframework.cloud.stream.binder.ConsumerProperties
import org.springframework.cloud.stream.binder.ProducerProperties
import org.springframework.messaging.MessageChannel

class NoOpBinder : Binder<MessageChannel, ConsumerProperties, ProducerProperties> {
    val logger = LoggerFactory.getLogger(javaClass)!!
    override fun bindConsumer(
        name: String,
        group: String,
        inboundBindTarget: MessageChannel,
        consumerProperties: ConsumerProperties
    ): Binding<MessageChannel> = NoOpBinding(name).also { logger.info("bindConsumer: $it") }

    override fun bindProducer(
        name: String,
        outboundBindTarget: MessageChannel,
        producerProperties: ProducerProperties
    ): Binding<MessageChannel> = NoOpBinding(name).also { logger.info("bindProducer: $it") }

    private class NoOpBinding(val binderName: String) : Binding<MessageChannel> {
        val logger = LoggerFactory.getLogger(javaClass)!!

        override fun getName() = binderName
        override fun unbind() {
            logger.info("unbind: $this")
        }

        override fun toString() = "NoOpBinding [$name]"
    }
}

Класс конфигурации: 

package com.demo

import org.springframework.context.annotation.Bean

// Warn: this class is referenced in META-INF/spring.binders and used by spring cloud stream to instantiate binders.
class NoOpBinderServiceConfigurer {

    @Bean
    fun noOpBinder() = NoOpBinder()

}

// Resources> Meta-Inf> spring .binders 

noop: com.demo.NoOpBinderServiceConfigurer

Укажите подшивку в файле конфигурации application.yml 

spring:
  cloud:
    stream:
      bindings:
        my-binding:
          destination: my-destination
          group: my-group
          binder: noop
0 голосов
/ 28 января 2020

Вы можете сделать это, отключив привязку kafka в приложении весенней загрузки

  1. Класс приложения 

    import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration;

@SpringBootApplication(exclude = KafkaAutoConfiguration.class)

public class Application {
  ...
}

  2. application.yml ( При использовании yml) 

    spring: 
  autoconfigure:
    exclude: org.org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration

  3. application.properties (при использовании свойств) 

    spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration
...