spring cloud bus整合kafka问题

[复制链接]
查看11 | 回复5 | 2021-1-27 07:03:57 | 显示全部楼层 |阅读模式
4.0.0
com.unionpay
cloud-platform
3.0.0
config-server

org.springframework.cloud
spring-cloud-config-server

org.springframework.cloud
spring-cloud-starter-bus-kafka



org.springframework.boot
spring-boot-maven-plugin

org.apache.maven.plugins
maven-compiler-plugin
1.8
1.8
UTF-8



packagecom.unionpay.config;
importorg.springframework.boot.autoconfigure.SpringBootApplication;
importorg.springframework.boot.builder.SpringApplicationBuilder;
importorg.springframework.cloud.config.server.EnableConfigServer;
@SpringBootApplication
@EnableConfigServer
publicclassConfigServerApplication{
publicstaticvoidmain(String[]args){
newSpringApplicationBuilder(ConfigServerApplication.class).web(true).run(args);
}
}







分 -->
回复

使用道具 举报

千问 | 2021-1-27 07:03:57 | 显示全部楼层
ErrorstartingApplicationContext.Todisplaytheauto-configurationreportre-runyourapplicationwith'debug'enabled.
2017-06-1318:49:54,434ERRORmaino.s.b.SpringApplication:815-Applicationstartupfailed
org.springframework.context.ApplicationContextException:Failedtostartbean'outputBindingLifecycle';nestedexceptionisorg.springframework.cloud.stream.binder.BinderException:Exceptionthrownwhilebuildingoutboundendpoint
atorg.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:178)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:50)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:348)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:151)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:114)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:879)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144)~[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atorg.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:545)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
atorg.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)~[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atorg.springframework.boot.SpringApplication.refresh(SpringApplication.java:737)~[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atorg.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:370)~[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atorg.springframework.boot.SpringApplication.run(SpringApplication.java:314)~[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atorg.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:134)[spring-boot-1.5.3.RELEASE.jar:1.5.3.RELEASE]
atcom.unionpay.config.ConfigServerApplication.main(ConfigServerApplication.java:12)[classes/:na]
Causedby:org.springframework.cloud.stream.binder.BinderException:Exceptionthrownwhilebuildingoutboundendpoint
atorg.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:122)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:55)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:152)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.cloud.stream.binding.BindingService.bindProducer(BindingService.java:125)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.cloud.stream.binding.BindableProxyFactory.bindOutputs(BindableProxyFactory.java:238)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.cloud.stream.binding.OutputBindingLifecycle.start(OutputBindingLifecycle.java:57)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:175)~[spring-context-4.3.8.RELEASE.jar:4.3.8.RELEASE]
...13commonframesomitted
Causedby:kafka.common.KafkaException:Failedtoparsethebrokerinfofromzookeeper:{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://BCQ8GV3A1IYY46G:9092"],"jmx_port":-1,"host":"BCQ8GV3A1IYY46G","timestamp":"1497348689612","port":9092,"version":4}
atkafka.cluster.Broker$.createBroker(Broker.scala:98)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.utils.ZkUtils.getBrokerInfo(ZkUtils.scala:814)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:250)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.utils.ZkUtils$$anonfun$getAllBrokersInCluster$2.apply(ZkUtils.scala:250)~[kafka_2.11-0.10.1.1.jar:na]
atscala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)~[scala-library-2.11.8.jar:na]
atscala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)~[scala-library-2.11.8.jar:na]
atscala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)~[scala-library-2.11.8.jar:na]
atscala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)~[scala-library-2.11.8.jar:na]
atscala.collection.TraversableLike$class.map(TraversableLike.scala:234)~[scala-library-2.11.8.jar:na]
atscala.collection.AbstractTraversable.map(Traversable.scala:104)~[scala-library-2.11.8.jar:na]
atkafka.utils.ZkUtils.getAllBrokersInCluster(ZkUtils.scala:250)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.admin.AdminUtils$.getBrokerMetadatas(AdminUtils.scala:391)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.admin.AdminUtils$.createTopic(AdminUtils.scala:413)~[kafka_2.11-0.10.1.1.jar:na]
atkafka.admin.AdminUtils.createTopic(AdminUtils.scala)~[kafka_2.11-0.10.1.1.jar:na]
atorg.springframework.cloud.stream.binder.kafka.admin.Kafka10AdminUtilsOperation.invokeCreateTopic(Kafka10AdminUtilsOperation.java:51)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner$1.doWithRetry(KafkaTopicProvisioner.java:205)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:286)~[spring-retry-1.2.0.RELEASE.jar:na]
atorg.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:163)~[spring-retry-1.2.0.RELEASE.jar:na]
atorg.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicAndPartitions(KafkaTopicProvisioner.java:199)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicsIfAutoCreateEnabledAndAdminUtilsPresent(KafkaTopicProvisioner.java:153)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:109)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:60)~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar:1.2.0.RELEASE]
atorg.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:108)~[spring-cloud-stream-1.2.1.RELEASE.jar:1.2.1.RELEASE]
...19commonframesomitted
Causedby:java.lang.NoClassDefFoundError:Couldnotinitializeclasskafka.utils.Json$
atkafka.cluster.Broker$.createBroker(Broker.scala:72)~[kafka_2.11-0.10.1.1.jar:na]
...41commonframesomitted

回复

使用道具 举报

千问 | 2021-1-27 07:03:57 | 显示全部楼层
我的也是类似的错误,请问你解决了吗?
回复

使用道具 举报

千问 | 2021-1-27 07:03:57 | 显示全部楼层
org.springframework.context.ApplicationContextException:Failedtostartbean'outputBindingLifecycle';nestedexceptionisjava.lang.ArrayStoreException:sun.reflect.annotation.TypeNotPresentExceptionProxy
atorg.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:178)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:50)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:348)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:151)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:114)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:880)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.refresh(SpringApplication.java:762)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:372)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.run(SpringApplication.java:316)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.run(SpringApplication.java:1187)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.run(SpringApplication.java:1176)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atcom.aviyy.test.demo.App.main(App.java:52)[classes/:na]
Causedby:java.lang.ArrayStoreException:sun.reflect.annotation.TypeNotPresentExceptionProxy
atsun.reflect.annotation.AnnotationParser.parseClassArray(AnnotationParser.java:724)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseArray(AnnotationParser.java:531)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseMemberValue(AnnotationParser.java:355)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotation2(AnnotationParser.java:286)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotations2(AnnotationParser.java:120)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotations(AnnotationParser.java:72)~[na:1.8.0_60]
atjava.lang.Class.createAnnotationData(Class.java:3521)~[na:1.8.0_60]
atjava.lang.Class.annotationData(Class.java:3510)~[na:1.8.0_60]
atjava.lang.Class.getAnnotations(Class.java:3446)~[na:1.8.0_60]
atorg.springframework.core.type.StandardAnnotationMetadata.(StandardAnnotationMetadata.java:68)~[spring-core-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.beans.factory.annotation.AnnotatedGenericBeanDefinition.(AnnotatedGenericBeanDefinition.java:56)~[spring-beans-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.annotation.AnnotatedBeanDefinitionReader.registerBean(AnnotatedBeanDefinitionReader.java:167)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.annotation.AnnotatedBeanDefinitionReader.registerBean(AnnotatedBeanDefinitionReader.java:142)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.context.annotation.AnnotatedBeanDefinitionReader.register(AnnotatedBeanDefinitionReader.java:131)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
atorg.springframework.boot.BeanDefinitionLoader.load(BeanDefinitionLoader.java:159)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.BeanDefinitionLoader.load(BeanDefinitionLoader.java:135)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.BeanDefinitionLoader.load(BeanDefinitionLoader.java:127)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.load(SpringApplication.java:704)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.prepareContext(SpringApplication.java:367)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.SpringApplication.run(SpringApplication.java:314)[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:134)~[spring-boot-1.4.7.RELEASE.jar:1.4.7.RELEASE]
atorg.springframework.cloud.stream.binder.DefaultBinderFactory.getBinderInstance(DefaultBinderFactory.java:208)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.cloud.stream.binder.DefaultBinderFactory.getBinder(DefaultBinderFactory.java:151)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.cloud.stream.binding.BindingService.getBinder(BindingService.java:155)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.cloud.stream.binding.BindingService.bindProducer(BindingService.java:111)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.cloud.stream.binding.BindableProxyFactory.bindOutputs(BindableProxyFactory.java:238)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.cloud.stream.binding.OutputBindingLifecycle.start(OutputBindingLifecycle.java:57)~[spring-cloud-stream-1.2.2.RELEASE.jar:1.2.2.RELEASE]
atorg.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:175)~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]
...14commonframesomitted
回复

使用道具 举报

千问 | 2021-1-27 07:03:57 | 显示全部楼层
前面还有报文
2017-08-1711:04:39.251INFO3680---[main]o.s.core.annotation.AnnotationUtils:Failedtointrospectannotationson[classorg.springframework.cloud.stream.binder.kafka.config.KafkaBinderConfiguration]:java.lang.ArrayStoreException:sun.reflect.annotation.TypeNotPresentExceptionProxy
2017-08-1711:04:39.255WARN3680---[main]o.s.boot.SpringApplication:Errorhandlingfailed(ApplicationEventMulticasternotinitialized-call'refresh'beforemulticastingeventsviathecontext:org.springframework.context.annotation.AnnotationConfigApplicationContext@b950f82:startupdate[ThuJan0108:00:00CST1970];parent:org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@7e5d9a50)
2017-08-1711:04:39.267ERROR3680---[main]o.s.boot.SpringApplication:Applicationstartupfailed
java.lang.ArrayStoreException:sun.reflect.annotation.TypeNotPresentExceptionProxy
atsun.reflect.annotation.AnnotationParser.parseClassArray(AnnotationParser.java:724)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseArray(AnnotationParser.java:531)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseMemberValue(AnnotationParser.java:355)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotation2(AnnotationParser.java:286)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotations2(AnnotationParser.java:120)~[na:1.8.0_60]
atsun.reflect.annotation.AnnotationParser.parseAnnotations(AnnotationParser.java:72)~[na:1.8.0_60]
atjava.lang.Class.createAnnotationData(Class.java:3521)~[na:1.8.0_60]
atjava.lang.Class.annotationData(Class.java:3510)~[na:1.8.0_60]
atjava.lang.Class.getAnnotations(Class.java:3446)~[na:1.8.0_60]
回复

使用道具 举报

千问 | 2021-1-27 07:03:57 | 显示全部楼层
楼主有没有把kafka.utils.Json点开看看是不是乱码,maven有时会出现文件下载不完整的情况,可以试试从maven的repository里面把这个jar包删了,重新构建一下
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

主题

0

回帖

4882万

积分

论坛元老

Rank: 8Rank: 8

积分
48824836
热门排行