diff --git a/src/common/metrics/src/guarded_metrics.rs b/src/common/metrics/src/guarded_metrics.rs
index e024ebaff8d17..809e205db0ec2 100644
--- a/src/common/metrics/src/guarded_metrics.rs
+++ b/src/common/metrics/src/guarded_metrics.rs
@@ -86,7 +86,7 @@ macro_rules! register_guarded_int_gauge_vec_with_registry {
 #[macro_export]
 macro_rules! register_guarded_uint_gauge_vec_with_registry {
     ($NAME:expr, $HELP:expr, $LABELS_NAMES:expr, $REGISTRY:expr $(,)?) => {{
-        let inner = prometheus::core::GenericGaugeVec::<AtomicU64>::new(
+        let inner = prometheus::core::GenericGaugeVec::<prometheus::core::AtomicU64>::new(
             prometheus::opts!($NAME, $HELP),
             $LABELS_NAMES,
         );
diff --git a/src/connector/src/source/kafka/stats.rs b/src/connector/src/source/kafka/stats.rs
index 7a36c4d1fffea..9e8285a8cc486 100644
--- a/src/connector/src/source/kafka/stats.rs
+++ b/src/connector/src/source/kafka/stats.rs
@@ -12,7 +12,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use prometheus::core::AtomicU64;
 use prometheus::Registry;
 use rdkafka::statistics::{Broker, ConsumerGroup, Partition, Topic, Window};
 use rdkafka::Statistics;