Merge pull request #23 from Overmuse/SR/optimize_for_speed

update settings for faster sending to kafka
Overmuse · Apr 20, 2021 · c19b5ed · c19b5ed
2 parents d5e6afc + 3f5baa5
commit c19b5ed
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "polygon-data-relay"
-version = "1.1.1"
+version = "1.2.0"
 authors = ["Sebastian Rollen <[email protected]>"]
 edition = "2018"
 
@@ -13,7 +13,7 @@ anyhow = "1.0"
 config = "0.11.0"
 dotenv = "0.15"
 futures = "0.3"
-kafka-settings = { git = "ssh://[email protected]/Overmuse/kafka-settings", tag = "v0.2.2" }
+kafka-settings = { git = "ssh://[email protected]/Overmuse/kafka-settings", tag = "v0.3.1" }
 polygon = { git = "ssh://[email protected]/Overmuse/polygon", tag = "v0.6.2", default-features = false, features = ["ws"] }
 rdkafka = { version = "0.26", features = ["ssl-vendored"] }
 sentry = { version = "0.21.0", features = ["anyhow"] }

diff --git a/src/relay.rs b/src/relay.rs
@@ -66,7 +66,7 @@ pub async fn run(
                     Err(e) => {
                         let e = e.into();
                         sentry_anyhow::capture_anyhow(&e);
-                        error!("Failed to receive message from the WebSocket: {}", e)
+                        panic!("Failed to receive message from the WebSocket: {}", e)
                     }
                 }
             },