diff --git a/src/main/java/com/snowflake/kafka/connector/internal/telemetry/TelemetryConstants.java b/src/main/java/com/snowflake/kafka/connector/internal/telemetry/TelemetryConstants.java
index cf43c2075..1a1ac72d1 100644
--- a/src/main/java/com/snowflake/kafka/connector/internal/telemetry/TelemetryConstants.java
+++ b/src/main/java/com/snowflake/kafka/connector/internal/telemetry/TelemetryConstants.java
@@ -9,27 +9,21 @@ public final class TelemetryConstants {
   public static final String STAGE_NAME = "stage_name";
   public static final String PIPE_NAME = "pipe_name";
 
-  public static final String TOPIC_NAME = "topic_name";
-  public static final String PARTITION = "partition";
-  public static final String CHANNEL_NAME = "channel_name";
-
-  public static final String PROCESSED_OFFSET = "processed_offset";
-  public static final String FLUSHED_OFFSET = "flushed_offset";
-  public static final String COMMITTED_OFFSET = "committed_offset";
-  public static final String PURGED_OFFSET = "purged_offset";
-  public static final String OFFSET_PERSISTED_IN_SNOWFLAKE = "offset_persisted_in_snowflake";
-  public static final String LATEST_CONSUMER_OFFSET = "latest_consumer_offset";
+  public static final String PROCESSED_OFFSET = "processed-offset";
+  public static final String FLUSHED_OFFSET = "flushed-offset";
+  public static final String COMMITTED_OFFSET = "committed-offset";
+  public static final String PURGED_OFFSET = "purged-offset";
 
   public static final String RECORD_NUMBER = "record_number";
   public static final String BYTE_NUMBER = "byte_number";
 
-  public static final String FILE_COUNT_ON_STAGE = "file_count_on_stage";
-  public static final String FILE_COUNT_ON_INGESTION = "file_count_on_ingestion";
-  public static final String FILE_COUNT_PURGED = "file_count_purged";
+  public static final String FILE_COUNT_ON_STAGE = "file-count-on-stage";
+  public static final String FILE_COUNT_ON_INGESTION = "file-count-on-ingestion";
+  public static final String FILE_COUNT_PURGED = "file-count-purged";
   public static final String FILE_COUNT_TABLE_STAGE_INGEST_FAIL =
       "file_count_table_stage_ingest_fail";
   public static final String FILE_COUNT_TABLE_STAGE_BROKEN_RECORD =
-      "file_count_table_stage_broken_record";
+      "file-count-table-stage-broken-record";
 
   public static final String CLEANER_RESTART_COUNT = "cleaner_restart_count";