springboot启动时kafka未启动?
spingboot启动时kafka未启动的原因是服务异常,而导致异常的原因可能是kafka报错,进程被干掉,需要使用exit函数。
SpringBoot配置kafka服务,如果服务异常会导致系统无法正常启动,解决该问题第一步,可以应用Spring的@Conditional注解为Kafka的配置类添加条件注解,使用动态启动,能获取到ioc的beanfactory,获取类加载器,获取环境信息,获取到bean注册的注册类,获取配置信息,文件以及端口,判断服务器正常连接,能否联通,
第二步:在所有与kafka相关的配置类中添加注解。
Conditional(MyCondition.Class.Conditional保证在符合MyCondition中match方法时才能创建对应bean,只有验证服务可以访问通过的情况下,容器才能初始化Kafka相关类。