diff --git a/tests-integration/src/tests/test_util.rs b/tests-integration/src/tests/test_util.rs
index 7bb29ce3318e..491a93086953 100644
--- a/tests-integration/src/tests/test_util.rs
+++ b/tests-integration/src/tests/test_util.rs
@@ -21,6 +21,7 @@ use common_query::Output;
 use common_recordbatch::util;
 use common_telemetry::warn;
 use common_test_util::find_workspace_path;
+use common_wal::config::kafka::common::KafkaTopicConfig;
 use common_wal::config::kafka::{DatanodeKafkaConfig, MetasrvKafkaConfig};
 use common_wal::config::{DatanodeWalConfig, MetasrvWalConfig};
 use frontend::instance::Instance;
@@ -231,8 +232,11 @@ pub(crate) async fn standalone_with_kafka_wal() -> Option<Box<dyn RebuildableMoc
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            topic_name_prefix: test_name.to_string(),
-            num_topics: 3,
+            kafka_topic: KafkaTopicConfig {
+                topic_name_prefix: test_name.to_string(),
+                num_topics: 3,
+                ..Default::default()
+            },
             ..Default::default()
         }));
     let instance = TestContext::new(MockInstanceBuilder::Standalone(builder)).await;
@@ -261,8 +265,11 @@ pub(crate) async fn distributed_with_kafka_wal() -> Option<Box<dyn RebuildableMo
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            topic_name_prefix: test_name.to_string(),
-            num_topics: 3,
+            kafka_topic: KafkaTopicConfig {
+                topic_name_prefix: test_name.to_string(),
+                num_topics: 3,
+                ..Default::default()
+            },
             ..Default::default()
         }));
     let instance = TestContext::new(MockInstanceBuilder::Distributed(builder)).await;
diff --git a/tests-integration/tests/region_migration.rs b/tests-integration/tests/region_migration.rs
index 24d77a834592..73316685c60d 100644
--- a/tests-integration/tests/region_migration.rs
+++ b/tests-integration/tests/region_migration.rs
@@ -23,6 +23,7 @@ use common_recordbatch::RecordBatches;
 use common_telemetry::info;
 use common_test_util::recordbatch::check_output_stream;
 use common_test_util::temp_dir::create_temp_dir;
+use common_wal::config::kafka::common::KafkaTopicConfig;
 use common_wal::config::kafka::{DatanodeKafkaConfig, MetasrvKafkaConfig};
 use common_wal::config::{DatanodeWalConfig, MetasrvWalConfig};
 use datatypes::prelude::ScalarVector;
@@ -118,8 +119,11 @@ pub async fn test_region_migration(store_type: StorageType, endpoints: Vec<Strin
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -247,8 +251,11 @@ pub async fn test_metric_table_region_migration_by_sql(
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -369,8 +376,11 @@ pub async fn test_region_migration_by_sql(store_type: StorageType, endpoints: Ve
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -490,8 +500,11 @@ pub async fn test_region_migration_multiple_regions(
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -626,8 +639,11 @@ pub async fn test_region_migration_all_regions(store_type: StorageType, endpoint
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -757,8 +773,11 @@ pub async fn test_region_migration_incorrect_from_peer(
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))
@@ -831,8 +850,11 @@ pub async fn test_region_migration_incorrect_region_id(
         }))
         .with_metasrv_wal_config(MetasrvWalConfig::Kafka(MetasrvKafkaConfig {
             broker_endpoints: endpoints,
-            num_topics: 3,
-            topic_name_prefix: Uuid::new_v4().to_string(),
+            kafka_topic: KafkaTopicConfig {
+                num_topics: 3,
+                topic_name_prefix: Uuid::new_v4().to_string(),
+                ..Default::default()
+            },
             ..Default::default()
         }))
         .with_shared_home_dir(Arc::new(home_dir))