即使Kakfa处于关闭状态,应用程序也会启动

问题描述 投票:0回答:1

我一直在研究弹簧云探测,以将迹线推至zipkin,我们正在借助spring-cloud-starter-stream-kafkaspring-cloud-sleuth-stream将迹线推至Kafka。>

下面是我添加到我的应用程序中的依赖项

compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', version: '1.0.0.RELEASE'
compile group: 'org.springframework.cloud', name: 'spring-cloud-sleuth-stream', version: '1.2.4.RELEASE'
compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-stream-kafka', version: '1.2.0.RELEASE'

而且我的应用程序属性只有kafka代理,默认情况下,该代理将跟踪推送到sleuth主题spring.cloud.stream.kafka.binder.brokers=locahost:9092

截至目前,一切正常[[但我无法弄清楚如果Kafka关闭了,是否可以启动应用程序?

[从日志中我看到应用程序已启动,但是由于它将无法连接到kafka,因此我们将无法访问任何端点(在下面添加了一些日志)。正在寻找此解决方案,因为推送跟踪不是我的应用程序的主要功能。

Started testApp in 0.299 seconds (JVM running for 20.241) [WARN] 2019-12-19 13:27:56,183 main org.apache.kafka.clients.producer.ProducerConfig - {} - The configuration 'key.deserializer' was supplied but isn't a known config. [WARN] 2019-12-19 13:27:56,183 main org.apache.kafka.clients.producer.ProducerConfig - {} - The configuration 'value.deserializer' was supplied but isn't a known config. [INFO] 2019-12-19 13:27:56,184 main org.apache.kafka.common.utils.AppInfoParser - {} - Kafka version : 0.11.0.0 [INFO] 2019-12-19 13:27:56,184 main org.apache.kafka.common.utils.AppInfoParser - {} - Kafka commitId : cb8625948210849f [WARN] 2019-12-19 13:27:56,225 kafka-producer-network-thread | producer-1 org.apache.kafka.clients.NetworkClient - {} - Connection to node -1 could not be established. Broker may not be available. [WARN] 2019-12-19 13:27:56,335 kafka-producer-network-thread | producer-1 org.apache.kafka.clients.NetworkClient - {} - Connection to node -1 could not be established. Broker may not be available. [WARN] 2019-12-19 13:27:56,390 kafka-producer-network-thread | producer-1 org.apache.kafka.clients.NetworkClient - {} - Connection to node -1 could not be established. Broker may not be available.

[我一直在研究春季云搜索,将痕迹推到zipkin,我们正在借助spring-cloud-starter-stream-kafka和spring-cloud-sleuth-stream将跟踪推到Kafka,下面是...] >
spring-cloud-stream spring-cloud-sleuth
1个回答
1
投票
您的版本是错误的。请不要自己设置版本,请使用如下所示的Spring Cloud BOM(spring-cloud-dependencies)依赖性管理

buildscript { dependencies { classpath "io.spring.gradle:dependency-management-plugin:0.5.2.RELEASE" } } apply plugin: "io.spring.dependency-management" dependencyManagement { imports { mavenBom "org.springframework.cloud:spring-cloud-sleuth:${springCloudSleuthVersion}" } } dependencies { compile 'org.springframework.cloud:spring-cloud-starter-sleuth' }

© www.soinside.com 2019 - 2024. All rights reserved.