admin管理员组

文章数量:1641943

在所有卡夫卡相关的配置类上加，此注解

@Conditional(MyCondition.class)

其中MyCondition,自己实现

package com.ireal.crpas.kafkademo.test;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.context.annotation.Condition;
import org.springframework.context.annotation.ConditionContext;
import org.springframework.core.env.Environment;
import org.springframework.core.type.AnnotatedTypeMetadata;

import java.io.IOException;
import java.InetSocketAddress;
import java.Socket;
import java.URI;
import java.URISyntaxException;
import java.util.Properties;

/**
 * kafka 动态启动
 * kafka代理服务器正常时启动kafka服务
 * kafka代理服务器不可用时，不启动kafka服务

本文标签： 也能动态bootSpringSpringBoot

版权声明：本文标题：spring boot kafka 动态启动，springboot集成kafka，无法连接时，也能正常启动 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/xitong/1729330767a1196365.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。