diff --git a/src/connector/src/sink/kafka.rs b/src/connector/src/sink/kafka.rs index f15173a4aabf6..7bdc40e49877a 100644 --- a/src/connector/src/sink/kafka.rs +++ b/src/connector/src/sink/kafka.rs @@ -257,8 +257,6 @@ impl KafkaConfig { pub(crate) fn set_client(&self, c: &mut rdkafka::ClientConfig) { self.rdkafka_properties_common.set_client(c); self.rdkafka_properties_producer.set_client(c); - - tracing::info!("kafka client starts with: {:?}", c); } } diff --git a/src/connector/src/sink/remote.rs b/src/connector/src/sink/remote.rs index 3ab7e90a69367..9630072194b38 100644 --- a/src/connector/src/sink/remote.rs +++ b/src/connector/src/sink/remote.rs @@ -680,11 +680,7 @@ impl RemoteCoordinator { .start_sink_coordinator_stream(param.clone()) .await?; - tracing::trace!( - "{:?} RemoteCoordinator started with properties: {:?}", - R::SINK_NAME, - ¶m.properties - ); + tracing::trace!("{:?} RemoteCoordinator started", R::SINK_NAME,); Ok(RemoteCoordinator { stream_handle }) } diff --git a/src/connector/src/source/kafka/mod.rs b/src/connector/src/source/kafka/mod.rs index 91d4ccce5ca88..a93080e3ddbdc 100644 --- a/src/connector/src/source/kafka/mod.rs +++ b/src/connector/src/source/kafka/mod.rs @@ -159,8 +159,6 @@ impl KafkaProperties { pub fn set_client(&self, c: &mut rdkafka::ClientConfig) { self.rdkafka_properties_common.set_client(c); self.rdkafka_properties_consumer.set_client(c); - - tracing::info!("kafka client starts with: {:?}", c); } } diff --git a/src/connector/src/source/reader/reader.rs b/src/connector/src/source/reader/reader.rs index 9a1f94de0fb8d..d702426554a23 100644 --- a/src/connector/src/source/reader/reader.rs +++ b/src/connector/src/source/reader/reader.rs @@ -156,7 +156,7 @@ impl SourceReader { } else { let to_reader_splits = splits.into_iter().map(|split| vec![split]); try_join_all(to_reader_splits.into_iter().map(|splits| { - tracing::debug!(?splits, ?prop, "spawning connector split reader"); + tracing::debug!(?splits, "spawning connector split reader"); let props = prop.clone(); let data_gen_columns = data_gen_columns.clone(); let parser_config = parser_config.clone();