2017-11-16 10 views
0

트위터 소스 용 스프링 클라우드 스트림 앱을 실행 중입니다. docker 이미지가 성공적으로 시작되고 10 초 후에 org.apache.kafka.common.errors.TimeoutException을 throw하여 실패합니다. 60000 ms 후에 메타 데이터를 업데이트하지 못했습니다. 스프링 클라우드 스트림 앱 스타터가 10 초 후에 오류가 발생합니다. BinderException : 바인더를 초기화 할 수 없습니다.

전체 스택 추적을 참조하십시오

,

2017-11-16 06:41:33,293 INFO main o.a.k.c.u.AppInfoParser:83 - Kafka version : 0.10.1.1 
2017-11-16 06:41:33,294 INFO main o.a.k.c.u.AppInfoParser:84 - Kafka commitId : f10ef2720b03b247 
2017-11-16 06:51:39,822 ERROR main o.s.c.s.b.k.p.KafkaTopicProvisioner:253 - Cannot initialize Binder 
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms. 
2017-11-16 06:51:39,822 WARN main o.s.b.c.e.AnnotationConfigEmbeddedWebApplicationContext:550 - Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context.ApplicationContextException: Failed to start bean 'outputBindingLifecycle'; nested exception is org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder: 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:449 - Unregistering JMX-exposed beans on shutdown 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:241 - Unregistering JMX-exposed beans 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:375 - Summary on shutdown: output 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:375 - Summary on shutdown: nullChannel 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:375 - Summary on shutdown: errorChannel 
2017-11-16 06:51:39,825 INFO main o.s.i.m.IntegrationMBeanExporter:378 - Summary on shutdown: _org.springframework.integration.errorLogger.handler 
2017-11-16 06:51:39,826 INFO main o.s.j.e.a.AnnotationMBeanExporter:449 - Unregistering JMX-exposed beans on shutdown 
2017-11-16 06:51:39,826 INFO main o.s.j.e.a.AnnotationMBeanExporter:241 - Unregistering JMX-exposed beans 
2017-11-16 06:51:39,827 INFO main o.s.s.c.ThreadPoolTaskScheduler:203 - Shutting down ExecutorService 'taskScheduler' 
2017-11-16 06:51:39,827 INFO main o.s.c.a.AnnotationConfigApplicationContext:987 - Closing org.spring[email protected]ba1f559: startup date [Thu Nov 16 06:41:26 GMT 2017]; parent: org.springframework.boot[email protected]131276c2 
2017-11-16 06:51:39,829 INFO main o.a.c.c.StandardService:179 - Stopping service Tomcat 
2017-11-16 06:51:39,993 INFO main o.s.b.a.l.AutoConfigurationReportLoggingInitializer:101 - 

Error starting ApplicationContext. To display the auto-configuration report re-run your application with 'debug' enabled. 
2017-11-16 06:51:40,172 ERROR main o.s.b.SpringApplication:815 - Application startup failed 
org.springframework.context.ApplicationContextException: Failed to start bean 'outputBindingLifecycle'; nested exception is org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder: 
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:178) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:50) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:348) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:151) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:114) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:879) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144) ~[spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:545) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122) ~[spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:737) [spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:370) [spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:314) [spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1162) [spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1151) [spring-boot-1.5.2.RELEASE.jar!/:1.5.2.RELEASE] 
    at org.springframework.cloud.stream.app.twitterstream.source.kafka.TwitterstreamSourceKafka10Application.main(TwitterstreamSourceKafka10Application.java:29) [classes!/:1.2.0.RELEASE] 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_74] 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_74] 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_74] 
    at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_74] 
    at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48) [twitterstream-source-kafka-10.jar:1.2.0.RELEASE] 
    at org.springframework.boot.loader.Launcher.launch(Launcher.java:87) [twitterstream-source-kafka-10.jar:1.2.0.RELEASE] 
    at org.springframework.boot.loader.Launcher.launch(Launcher.java:50) [twitterstream-source-kafka-10.jar:1.2.0.RELEASE] 
    at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:51) [twitterstream-source-kafka-10.jar:1.2.0.RELEASE] 
Caused by: org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder: 
    at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.getPartitionsForTopic(KafkaTopicProvisioner.java:254) ~[spring-cloud-stream-binder-kafka-core-1.2.0.RELEASE.jar!/:1.2.0.RELEASE] 
    at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:148) ~[spring-cloud-stream-binder-kafka-1.2.0.RELEASE.jar!/:1.2.0.RELEASE] 
    at org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.createProducerMessageHandler(KafkaMessageChannelBinder.java:87) ~[spring-cloud-stream-binder-kafka-1.2.0.RELEASE.jar!/:1.2.0.RELEASE] 
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:109) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:55) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:152) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binding.BindingService.bindProducer(BindingService.java:125) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binding.BindableProxyFactory.bindOutputs(BindableProxyFactory.java:238) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.cloud.stream.binding.OutputBindingLifecycle.start(OutputBindingLifecycle.java:57) ~[spring-cloud-stream-1.2.1.RELEASE.jar!/:1.2.1.RELEASE] 
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:175) ~[spring-context-4.3.7.RELEASE.jar!/:4.3.7.RELEASE] 
    ... 22 common frames omitted 
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms. 

카프카 버전 : 또한 나는 카프카-10 호환 고정 표시기 이미지를 사용하고 kafka_2.10-0.10.1.0

.

+0

스택 추적에 프로비저닝 예외가있는 것 같습니다. 이것은 이미 기존 주제입니까? 그렇다면 몇 개의 파티션이 있습니까? 시작시 파티션 수를 변경하려고합니까? – sobychacko

+0

이것은 새로운 주제입니다. kafka 미들웨어로 봄 구름 스트림 앱 시작 Twitter 소스를 시작합니다. 나는 어떤 파티션도 명시 적으로 수정하지 않을 것이다. – Krishas

+0

스프링 클라우드 스트림의 '1.3.0.RELEASE'를 사용하도록 앱을 업그레이드하고 문제가 지속되는지 확인할 수 있습니까? 무슨 일이 진행되는지 더 자세히 조사 할 것이지만 1.3.0에서 어떻게 작동하는지 확인하는 것이 좋습니다. – sobychacko

답변

0

문제가 해결되었습니다. 카프카와의 연결 문제였습니다.

내 리스너 구성

listeners=PLAINTEXT://localhost:9092하고 있었고, 난 다른 노드에서 연결을 시도했다. 청취자 구성을 listeners=PLAINTEXT://<hostname>:9092으로 바꿨을 때 오류가 사라졌습니다.

그러나 왜 spring cloud stream app이 시작시 예외를 발생시키지 않는지 확신 할 수 없습니다. !!!