我一直在研究弹簧云探测,以将迹线推至zipkin,我们正在借助spring-cloud-starter-stream-kafka
和spring-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,下面是...] >
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'
}