chore: add logs

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(_)

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,
         })?;

server/src/mysql/service.rs

@@ -51,14 +51,14 @@ 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(),
             self.socket_addr,
             self.timeout,
             rx,
         )));
-        info!("Mysql service listens on {}", self.socket_addr);
         Ok(())
     }