fix(chore): fix uint gauge vec macro (#19909)

Signed-off-by: MrCroxx <[email protected]>
risingwavelabs · Dec 24, 2024 · d7f8b4e · d7f8b4e
1 parent 3431eab
commit d7f8b4e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git 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
@@ -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;