code: @Retryable(maxAttemptsExpression = "${application.retry.max-attempts}",
          backoff = @Backoff(delayExpression = "${application.retry.delay}",
              multiplierExpression = "${application.retry.multiplier}"))
      public void consumeEvent(ConsumerRecord<String, String> message) {
          MdcUtils.putRid();
          try {
              log.info("Consume event from topic [{}]", message.topic());
              try {
                  ConfigEvent event = mapper.readValue(message.value(), ConfigEvent.class);
  
                  log.info("Process event from topic [{}], event_id ='{}'",
                      message.topic(), event.getEventId());
                  configService.updateConfigurations(event.getCommit(), event.getPaths());
              } catch (IOException e) {
                  log.error("Config topic message has incorrect format: '{}'", message.value(), e);
              }
          } finally {
              MdcUtils.removeRid();
          }
      }
docs: Consume tenant command event message.
  
  @param message the tenant command event message