diff --git a/tests-integration/src/wal_util/kafka.rs b/tests-integration/src/wal_util/kafka.rs index 2e14f90fc499..abde462d720d 100644 --- a/tests-integration/src/wal_util/kafka.rs +++ b/tests-integration/src/wal_util/kafka.rs @@ -19,6 +19,8 @@ pub mod runtime; #[macro_export] macro_rules! start_kafka { () => { - let _ = $crate::wal_util::kafka::runtime::Runtime::default().start().await; + let _ = $crate::wal_util::kafka::runtime::Runtime::default() + .start() + .await; }; }