From 92ae04870d04573a811c3371dc4ff903b794fc73 Mon Sep 17 00:00:00 2001
From: Paulo Cesar <461084+pocesar@users.noreply.github.com>
Date: Tue, 27 Aug 2024 20:17:55 -0300
Subject: [PATCH] Revert "fix: pubsub emulator"

This reverts commit 34ff1e3fa0588736bb3e83185bca79677b4b7e57.
---
 src/sinks/gcp_pubsub/run.rs   | 3 ---
 src/sinks/gcp_pubsub/setup.rs | 9 ---------
 2 files changed, 12 deletions(-)

diff --git a/src/sinks/gcp_pubsub/run.rs b/src/sinks/gcp_pubsub/run.rs
index 621336ab..777e9b7f 100644
--- a/src/sinks/gcp_pubsub/run.rs
+++ b/src/sinks/gcp_pubsub/run.rs
@@ -49,9 +49,6 @@ pub fn writer_loop(
     retry_policy: &retry::Policy,
     ordering_key: &str,
     attributes: &GenericKV,
-    emulator: bool,
-    emulator_endpoint: &Option<String>,
-    emulator_project_id: &Option<String>,
     utils: Arc<Utils>,
 ) -> Result<(), crate::Error> {
     let rt = tokio::runtime::Builder::new_current_thread()
diff --git a/src/sinks/gcp_pubsub/setup.rs b/src/sinks/gcp_pubsub/setup.rs
index a1cdd064..033bcc19 100644
--- a/src/sinks/gcp_pubsub/setup.rs
+++ b/src/sinks/gcp_pubsub/setup.rs
@@ -27,12 +27,6 @@ pub struct Config {
 impl SinkProvider for WithUtils<Config> {
     fn bootstrap(&self, input: StageReceiver) -> BootstrapResult {
         let topic_name = self.inner.topic.to_owned();
-        let mut use_emulator = self.inner.emulator.unwrap_or(false);
-        let emulator_endpoint = self.inner.emulator_endpoint.to_owned();
-        let emulator_project_id = self.inner.emulator_project_id.to_owned();
-        if use_emulator && (emulator_endpoint.is_none() || emulator_project_id.is_none()) {
-            use_emulator = false;
-        }
 
         let error_policy = self
             .inner
@@ -56,9 +50,6 @@ impl SinkProvider for WithUtils<Config> {
                 &retry_policy,
                 &ordering_key,
                 &attributes,
-                use_emulator,
-                &emulator_endpoint,
-                &emulator_project_id,
                 utils,
             )
             .expect("writer loop failed");