Микросервис не может быть включен, когда Кафка не работает - PullRequest
Новая
       8

Микросервис не может быть включен, когда Кафка не работает

0 голосов
/ 28 декабря 2018

После запуска моего приложения микро-сервисов через некоторое время 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();
...