diff --git a/components/message_queue/src/kafka/kafka_impl.rs b/components/message_queue/src/kafka/kafka_impl.rs
index e431a9a975..8e8145e7a2 100644
--- a/components/message_queue/src/kafka/kafka_impl.rs
+++ b/components/message_queue/src/kafka/kafka_impl.rs
@@ -200,7 +200,7 @@ impl MessageQueue for KafkaImpl {
 
         // Create topic in Kafka.
         let topic_management_config = &self.config.topic_management_config;
-        info!("Try to create topic:{} in kafka", topic_name);
+        info!("Try to create topic, name:{}.", topic_name);
         let result = self
             .controller_client
             .create_topic(
@@ -211,6 +211,7 @@ impl MessageQueue for KafkaImpl {
             )
             .await;
 
+        info!("Create topic finish, name:{}", topic_name);
         match result {
             // Race condition between check and creation action, that's OK.
             Ok(_)
diff --git a/server/src/http.rs b/server/src/http.rs
index b94e48714f..71ac083c21 100644
--- a/server/src/http.rs
+++ b/server/src/http.rs
@@ -7,7 +7,7 @@ use std::{
     time::Duration,
 };
 
-use log::error;
+use log::{error, info};
 use logger::RuntimeLevel;
 use profile::Profiler;
 use prom_remote_api::{types::RemoteStorageRef, web};
@@ -459,6 +459,11 @@ impl<Q: QueryExecutor + 'static> Builder<Q> {
             enable_tenant_as_schema: self.enable_tenant_as_schema,
         };
 
+        info!(
+            "HTTP server starts listening on {}",
+            &self.config.endpoint.to_string()
+        );
+
         let ip_addr: IpAddr = self.config.endpoint.addr.parse().context(ParseIpAddr {
             ip: self.config.endpoint.addr,
         })?;
diff --git a/server/src/mysql/service.rs b/server/src/mysql/service.rs
index 0b820f50ae..ca84db3261 100644
--- a/server/src/mysql/service.rs
+++ b/server/src/mysql/service.rs
@@ -51,6 +51,7 @@ impl<Q: QueryExecutor + 'static> MysqlService<Q> {
 
         let rt = self.runtimes.clone();
         self.tx = Some(tx);
+        info!("MySQL server starts listening on {}", self.socket_addr);
         self.join_handler = Some(rt.bg_runtime.spawn(Self::loop_accept(
             self.instance.clone(),
             self.runtimes.clone(),
@@ -58,7 +59,6 @@ impl<Q: QueryExecutor + 'static> MysqlService<Q> {
             self.timeout,
             rx,
         )));
-        info!("Mysql service listens on {}", self.socket_addr);
         Ok(())
     }