diff --git a/config/runtime.exs b/config/runtime.exs
index cfd6e3e63..d41f217f6 100644
--- a/config/runtime.exs
+++ b/config/runtime.exs
@@ -105,7 +105,5 @@ if config_env() == :prod do
     config :skate, Skate.Detours.TripModificationPublisher, start: true
   end
 
-  # There are currently issues with Distributed Elixir and our Data Pipelines.
-  # So we need to disable clustering in prod until we figure this out
-  # config :skate, DNSCluster, query: System.get_env("DNS_CLUSTER_QUERY") || :ignore
+  config :skate, DNSCluster, query: System.get_env("DNS_CLUSTER_QUERY") || :ignore
 end
diff --git a/lib/realtime/server.ex b/lib/realtime/server.ex
index 91cc60add..3cde364c8 100644
--- a/lib/realtime/server.ex
+++ b/lib/realtime/server.ex
@@ -510,7 +510,7 @@ defmodule Realtime.Server do
         :alerts -> "realtime_alerts"
       end
 
-    Phoenix.PubSub.broadcast(pubsub_name(), topic, {:new_realtime_data, state.ets})
+    Phoenix.PubSub.local_broadcast(pubsub_name(), topic, {:new_realtime_data, state.ets})
   end
 
   @spec block_is_active?(VehicleOrGhost.t()) :: boolean