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 991b8940292dd..1c98c416b19cb 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));