2017-03-21 40 views
0

我有 spring.cloud.stream.kafka.binder.brokers = KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes = ZKNODE_URL春天开机无法启动,并使用@EnableBinding和zkNodes不可

消费

如果我尝试运行spring boot consumer应用程序,并且zkNode未启动,则整个spring启动应用程序无法启动: rg.springframework.context.ApplicationContextException:无法启动bean'inputBindingLifecycle';嵌套异常是org.springframework.cloud.stream.binder.BinderException:启动消费者时抛出异常: ... 引起:org.I0Itec.zkclient.exception.ZkTimeoutException:无法在超时时间内连接到zookeeper服务器:10000

我的问题是: 如何克服这一点,并防止整个应用程序崩溃,以及如何定期重试连接?

回答

0

这是一个已知问题,正在使用Spring Cloud Stream进行跟踪Kafka联编程序here