java—当kafka关闭时,微服务无法启动

3ks5zfa0  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(193)

一旦我的微服务应用程序启动一段时间后,Kafka是由于这个原因,我的微服务应用程序被停止。有没有任何方法来启动我的服务,而不依赖Kafka?
请查看以下详细信息:
我的yml文件中的配置

kafka:
    host: dit-grid-kafka.ebiz.verizon.com
    port: 9092
    logTopic: ONEGRID_MS_APPLICATIONS_LOGS_TOPIC

在源代码中:

LoggerContext ctx = (LoggerContext) LogManager.getContext(false);
Configuration config= ctx.getConfiguration();

//kafka host name and port number
Property kafkaHost = Property.createProperty(AppConstants.KAFKA_BOOTSTRAP_SERVER, 
         prop.getKafkaHost()+":"+prop.getKafkaPort());
Property[] properties = new  Property[]{kafkaHost};
LoggerConfig loggerConfig = config.getLoggerConfig(LogManager.ROOT_LOGGER_NAME); 
//creating the pattern layout
Layout<? extends Serializable> layout = PatternLayout.newBuilder()
                               .withPattern("[%p] %m%n")
                               .build();
//creating the Kafka Appender and adding the layout
Appender appender  = KafkaAppender.newBuilder()
         .withName("org.apache.kafka")
         .setProperties(properties)
         .setSyncSend(false)
         .setTopic(prop.getLogTopic())
         .withLayout(layout)
         .setConfiguration(config)
         .build();
appender.start();

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题