diff --git a/app/lib/kafka.server.ts b/app/lib/kafka.server.ts
index f4cbc86532..5117d5bbc5 100644
--- a/app/lib/kafka.server.ts
+++ b/app/lib/kafka.server.ts
@@ -18,11 +18,11 @@ import {
 } from 'kafkajs'
 import memoizee from 'memoizee'
 
-import { domain, getEnvOrDie, getEnvOrDieInProduction } from './env.server'
+import { domain, getEnvOrDieInProduction } from './env.server'
 import type { User } from '~/routes/_auth/user.server'
 
-const client_id = getEnvOrDie('KAFKA_CLIENT_ID')
-const client_secret = getEnvOrDie('KAFKA_CLIENT_SECRET')
+const client_id = getEnvOrDieInProduction('KAFKA_CLIENT_ID') ?? ''
+const client_secret = getEnvOrDieInProduction('KAFKA_CLIENT_SECRET')
 const kafka = new Kafka({
   client_id,
   client_secret,