diff --git a/Cargo.lock b/Cargo.lock
index 09f658c8cd..f9c6c025ad 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1148,7 +1148,7 @@ dependencies = [
  "paste 1.0.12",
  "thiserror",
  "tokio",
- "tonic",
+ "tonic 0.8.3",
  "zstd 0.12.3+zstd.1.5.2",
 ]
 
@@ -1176,7 +1176,7 @@ checksum = "18d5d1c238f84dee01e671603c6a921868f3663256e0393c64ece88e58ee4869"
 dependencies = [
  "prost",
  "protoc-bin-vendored",
- "tonic",
+ "tonic 0.8.3",
  "tonic-build",
  "walkdir",
 ]
@@ -1438,6 +1438,42 @@ dependencies = [
  "crossbeam-utils 0.8.15",
 ]
 
+[[package]]
+name = "console-api"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c2895653b4d9f1538a83970077cb01dfc77a4810524e51a110944688e916b18e"
+dependencies = [
+ "prost",
+ "prost-types",
+ "tonic 0.9.2",
+ "tracing-core",
+]
+
+[[package]]
+name = "console-subscriber"
+version = "0.1.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "57ab2224a0311582eb03adba4caaf18644f7b1f10a760803a803b9b605187fc7"
+dependencies = [
+ "console-api",
+ "crossbeam-channel",
+ "crossbeam-utils 0.8.15",
+ "futures 0.3.28",
+ "hdrhistogram",
+ "humantime 2.1.0",
+ "prost-types",
+ "serde",
+ "serde_json",
+ "thread_local",
+ "tokio",
+ "tokio-stream",
+ "tonic 0.9.2",
+ "tracing",
+ "tracing-core",
+ "tracing-subscriber",
+]
+
 [[package]]
 name = "const-random"
 version = "0.1.15"
@@ -2161,7 +2197,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "aafcde04e90a5226a6443b7aabdb016ba2f8307c847d524724bd9b346dd1a2d3"
 dependencies = [
  "atty",
- "humantime",
+ "humantime 1.3.0",
  "log",
  "regex",
  "termcolor",
@@ -2207,7 +2243,7 @@ dependencies = [
  "prost",
  "tokio",
  "tokio-stream",
- "tonic",
+ "tonic 0.8.3",
  "tonic-build",
  "tower",
  "tower-service",
@@ -2684,6 +2720,19 @@ dependencies = [
  "ahash 0.8.3",
 ]
 
+[[package]]
+name = "hdrhistogram"
+version = "7.5.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7f19b9f54f7c7f55e31401bb647626ce0cf0f67b0004982ce815b3ee72a02aa8"
+dependencies = [
+ "base64 0.13.1",
+ "byteorder",
+ "flate2",
+ "nom 7.1.3",
+ "num-traits",
+]
+
 [[package]]
 name = "headers"
 version = "0.3.8"
@@ -2791,6 +2840,12 @@ dependencies = [
  "quick-error",
 ]
 
+[[package]]
+name = "humantime"
+version = "2.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9a3a5bfb195931eeb336b2a7b4d761daec841b97f947d34394601737a7bba5e4"
+
 [[package]]
 name = "hyper"
 version = "0.14.25"
@@ -3433,15 +3488,6 @@ dependencies = [
  "libc",
 ]
 
-[[package]]
-name = "matchers"
-version = "0.0.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f099785f7595cc4b4553a174ce30dd7589ef93391ff414dbb67f62392b9e0ce1"
-dependencies = [
- "regex-automata",
-]
-
 [[package]]
 name = "matchers"
 version = "0.1.0"
@@ -3547,7 +3593,7 @@ dependencies = [
  "snafu 0.6.10",
  "table_engine",
  "tokio",
- "tonic",
+ "tonic 0.8.3",
  "url",
 ]
 
@@ -4881,7 +4927,7 @@ dependencies = [
  "table_engine",
  "tokio",
  "tokio-stream",
- "tonic",
+ "tonic 0.8.3",
  "warp",
  "zstd 0.12.3+zstd.1.5.2",
 ]
@@ -5370,7 +5416,7 @@ dependencies = [
  "snafu 0.6.10",
  "table_engine",
  "tokio",
- "tonic",
+ "tonic 0.8.3",
 ]
 
 [[package]]
@@ -5878,7 +5924,7 @@ dependencies = [
  "table_engine",
  "tokio",
  "tokio-stream",
- "tonic",
+ "tonic 0.8.3",
  "wal",
  "warp",
  "zstd 0.12.3+zstd.1.5.2",
@@ -6502,7 +6548,7 @@ dependencies = [
  "parking_lot 0.12.1",
  "tempfile",
  "tracing-log",
- "tracing-subscriber 0.3.16",
+ "tracing-subscriber",
 ]
 
 [[package]]
@@ -6650,6 +6696,7 @@ dependencies = [
  "signal-hook-registry",
  "socket2",
  "tokio-macros",
+ "tracing",
  "windows-sys 0.45.0",
 ]
 
@@ -6832,6 +6879,34 @@ dependencies = [
  "tracing-futures",
 ]
 
+[[package]]
+name = "tonic"
+version = "0.9.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3082666a3a6433f7f511c7192923fa1fe07c69332d3c6a2e6bb040b569199d5a"
+dependencies = [
+ "async-trait",
+ "axum",
+ "base64 0.21.0",
+ "bytes 1.4.0",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http",
+ "http-body",
+ "hyper",
+ "hyper-timeout",
+ "percent-encoding",
+ "pin-project",
+ "prost",
+ "tokio",
+ "tokio-stream",
+ "tower",
+ "tower-layer",
+ "tower-service",
+ "tracing",
+]
+
 [[package]]
 name = "tonic-build"
 version = "0.8.4"
@@ -6933,13 +7008,13 @@ dependencies = [
 
 [[package]]
 name = "tracing-appender"
-version = "0.1.2"
+version = "0.2.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9965507e507f12c8901432a33e31131222abac31edd90cabbcf85cf544b7127a"
+checksum = "09d48f71a791638519505cefafe162606f706c25592e4bde4d97600c0195312e"
 dependencies = [
- "chrono",
  "crossbeam-channel",
- "tracing-subscriber 0.2.25",
+ "time 0.3.20",
+ "tracing-subscriber",
 ]
 
 [[package]]
@@ -6984,45 +7059,13 @@ dependencies = [
  "tracing-core",
 ]
 
-[[package]]
-name = "tracing-serde"
-version = "0.1.3"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bc6b213177105856957181934e4920de57730fc69bf42c37ee5bb664d406d9e1"
-dependencies = [
- "serde",
- "tracing-core",
-]
-
-[[package]]
-name = "tracing-subscriber"
-version = "0.2.25"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0e0d2eaa99c3c2e41547cfa109e910a68ea03823cccad4a0525dcbc9b01e8c71"
-dependencies = [
- "ansi_term",
- "chrono",
- "lazy_static",
- "matchers 0.0.1",
- "regex",
- "serde",
- "serde_json",
- "sharded-slab",
- "smallvec",
- "thread_local",
- "tracing",
- "tracing-core",
- "tracing-log",
- "tracing-serde",
-]
-
 [[package]]
 name = "tracing-subscriber"
-version = "0.3.16"
+version = "0.3.17"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a6176eae26dd70d0c919749377897b54a9276bd7061339665dd68777926b5a70"
+checksum = "30a651bc37f915e81f087d86e62a18eec5f79550c7faff886f7090b4ea757c77"
 dependencies = [
- "matchers 0.1.0",
+ "matchers",
  "nu-ansi-term",
  "once_cell",
  "regex",
@@ -7038,11 +7081,12 @@ dependencies = [
 name = "tracing_util"
 version = "1.2.0"
 dependencies = [
+ "console-subscriber",
  "lazy_static",
  "serde",
  "tracing",
  "tracing-appender",
- "tracing-subscriber 0.2.25",
+ "tracing-subscriber",
 ]
 
 [[package]]
diff --git a/Makefile b/Makefile
index 28688a8df4..9f2ba18e2d 100644
--- a/Makefile
+++ b/Makefile
@@ -29,6 +29,9 @@ build-arm64:
 	ls -alh
 	cd $(DIR); cargo build --release --no-default-features
 
+build-with-console:
+	ls -alh
+	cd $(DIR); RUSTFLAGS="--cfg tokio_unstable" cargo build --release
 test:
 	cd $(DIR); cargo test --workspace -- --test-threads=4
 
diff --git a/components/tracing_util/Cargo.toml b/components/tracing_util/Cargo.toml
index 217391a902..e52c3af7c2 100644
--- a/components/tracing_util/Cargo.toml
+++ b/components/tracing_util/Cargo.toml
@@ -11,8 +11,9 @@ workspace = true
 workspace = true
 
 [dependencies]
+console-subscriber = "0.1.9"
 lazy_static = { workspace = true }
 serde = { workspace = true }
-tracing = "0.1.26"
-tracing-appender = "0.1.2"
-tracing-subscriber = "0.2.20"
+tracing = "0.1.37"
+tracing-appender = "0.2.2"
+tracing-subscriber = "0.3.17"
diff --git a/components/tracing_util/src/logging.rs b/components/tracing_util/src/logging.rs
index ddf24dcdfe..08f1af9597 100644
--- a/components/tracing_util/src/logging.rs
+++ b/components/tracing_util/src/logging.rs
@@ -1,4 +1,4 @@
-// Copyright 2022 CeresDB Project Authors. Licensed under Apache-2.0.
+// Copyright 2022-2023 CeresDB Project Authors. Licensed under Apache-2.0.
 
 // Copyright 2020 Datafuse Labs.
 //
@@ -30,7 +30,7 @@ use tracing_appender::{
 };
 use tracing_subscriber::{
     fmt,
-    fmt::{time::ChronoLocal, Layer},
+    fmt::{time::Uptime, Layer},
     prelude::*,
     registry::Registry,
     EnvFilter,
@@ -90,6 +90,13 @@ pub struct Config {
     pub dir: String,
     /// The level of tracing.
     pub level: String,
+    /// Console config.
+    pub console: Option<ConsoleConfig>,
+}
+
+#[derive(Clone, Debug, Deserialize, Serialize)]
+pub struct ConsoleConfig {
+    pub port: u16,
 }
 
 impl Default for Config {
@@ -98,28 +105,52 @@ impl Default for Config {
             prefix: String::from("tracing"),
             dir: String::from("/tmp/ceresdb"),
             level: String::from("info"),
+            console: None,
         }
     }
 }
 
 /// Write logs to file and rotation.
-pub fn init_tracing_with_file(config: &Config, rotation: Rotation) -> WorkerGuard {
+pub fn init_tracing_with_file(config: &Config, node_addr: &str, rotation: Rotation) -> WorkerGuard {
     let file_appender = RollingFileAppender::new(rotation, &config.dir, &config.prefix);
     let (file_writer, file_guard) = tracing_appender::non_blocking(file_appender);
     let f_layer = Layer::new()
-        .with_timer(ChronoLocal::rfc3339())
+        .with_timer(Uptime::default())
         .with_writer(file_writer)
         .with_thread_ids(true)
         .with_thread_names(true)
         .with_ansi(false)
         .with_span_events(FmtSpan::ENTER | FmtSpan::CLOSE);
 
-    let subscriber = Registry::default()
-        .with(EnvFilter::new(&config.level))
-        .with(f_layer);
-
-    tracing::subscriber::set_global_default(subscriber)
-        .expect("error setting global tracing subscriber");
+    let subscriber = Registry::default().with(f_layer);
+    // TODO: subscriber.with(layer1) has the different type with
+    // subscriber.with(layer1).with(layer2)...
+    // So left some duplicated codes here. Maybe we can use marco to simplify
+    // it.
+    match &config.console {
+        Some(console) => {
+            let console_addr = format!("{}:{}", node_addr, console.port);
+            let console_addr: std::net::SocketAddr = console_addr
+                .parse()
+                .unwrap_or_else(|_| panic!("invalid tokio console addr:{console_addr}"));
+            let directives = format!("tokio=trace,runtime=trace,{}", config.level);
+
+            // It is part of initializing logger, so just print it to stdout.
+            println!("Tokio console server tries to listen on {console_addr}...");
+            let subscriber = subscriber.with(EnvFilter::new(directives)).with(
+                console_subscriber::ConsoleLayer::builder()
+                    .server_addr(console_addr)
+                    .spawn(),
+            );
+            tracing::subscriber::set_global_default(subscriber)
+                .expect("error setting global tracing subscriber");
+        }
+        None => {
+            let subscriber = subscriber.with(EnvFilter::new(&config.level));
+            tracing::subscriber::set_global_default(subscriber)
+                .expect("error setting global tracing subscriber");
+        }
+    };
 
     file_guard
 }
@@ -150,7 +181,7 @@ fn init_file_subscriber(app_name: &str, dir: &str) -> (WorkerGuard, impl Subscri
     let (writer, writer_guard) = tracing_appender::non_blocking(f);
 
     let f_layer = Layer::new()
-        .with_timer(ChronoLocal::rfc3339())
+        .with_timer(Uptime::default())
         .with_writer(writer)
         .with_thread_ids(true)
         .with_thread_names(false)
diff --git a/src/setup.rs b/src/setup.rs
index 45ba0e9137..2e5dc7f83f 100644
--- a/src/setup.rs
+++ b/src/setup.rs
@@ -51,7 +51,7 @@ pub fn setup_logger(config: &Config) -> RuntimeLevel {
 
 /// Setup tracing with given `config`, returns the writer guard.
 pub fn setup_tracing(config: &Config) -> WorkerGuard {
-    tracing_util::init_tracing_with_file(&config.tracing, Rotation::NEVER)
+    tracing_util::init_tracing_with_file(&config.tracing, &config.node.addr, Rotation::NEVER)
 }
 
 fn build_runtime(name: &str, threads_num: usize) -> runtime::Runtime {