From 84f8035b4e5e72f5725de094f67e2f69896250c1 Mon Sep 17 00:00:00 2001 From: Xing Wang <83489178+ciaocloud@users.noreply.github.com> Date: Wed, 9 Jun 2021 11:59:25 -0500 Subject: [PATCH] Log number of seconds it takes the broker to bootstrap. (#10819) Use TimeUnit for the conversion, changed bootstrap_second log format. --- .../main/java/org/apache/pulsar/broker/PulsarService.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java index 991b8940292dd9..1c98c416b19cb1 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java @@ -568,6 +568,8 @@ public void start() throws PulsarServerException { PulsarVersion.getBuildHost(), PulsarVersion.getBuildTime()); + long startTimestamp = System.currentTimeMillis(); // start time mills + mutex.lock(); try { if (state != State.Init) { @@ -802,13 +804,15 @@ config, localMetadataStore, getZkClient(), bkClientFactory, ioEventLoopGroup this.resourceUsageTransportManager = (ResourceUsageTransportManager) object; } + long currentTimestamp = System.currentTimeMillis(); + final long bootstrapTimeSeconds = TimeUnit.MILLISECONDS.toSeconds(currentTimestamp - startTimestamp); + final String bootstrapMessage = "bootstrap service " + (config.getWebServicePort().isPresent() ? "port = " + config.getWebServicePort().get() : "") + (config.getWebServicePortTls().isPresent() ? ", tls-port = " + config.getWebServicePortTls() : "") + (config.getBrokerServicePort().isPresent() ? ", broker url= " + brokerServiceUrl : "") + (config.getBrokerServicePortTls().isPresent() ? ", broker tls url= " + brokerServiceUrlTls : ""); - LOG.info("messaging service is ready"); - + LOG.info("messaging service is ready, bootstrap_seconds={}", bootstrapTimeSeconds); LOG.info("messaging service is ready, {}, cluster={}, configs={}", bootstrapMessage, config.getClusterName(), ReflectionToStringBuilder.toString(config));