diff --git a/indexer/services/socks/src/lib/message-forwarder.ts b/indexer/services/socks/src/lib/message-forwarder.ts index f088ecc1e8..5d928ed697 100644 --- a/indexer/services/socks/src/lib/message-forwarder.ts +++ b/indexer/services/socks/src/lib/message-forwarder.ts @@ -3,7 +3,6 @@ import { logger, InfoObject, safeJsonStringify, - STATS_NO_SAMPLING, } from '@dydxprotocol-indexer/base'; import { updateOnMessageFunction } from '@dydxprotocol-indexer/kafka'; import { KafkaMessage } from 'kafkajs'; @@ -147,7 +146,7 @@ export class MessageForwarder { stats.timing( `${config.SERVICE_NAME}.message_time_since_received`, startForwardMessage - Number(originalMessageTimestamp), - STATS_NO_SAMPLING, + config.MESSAGE_FORWARDER_STATSD_SAMPLE_RATE, { topic, event_type: String(message.headers?.event_type),