diff --git a/Cargo.toml b/Cargo.toml
index 0ba6d54..8cf8b64 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -10,8 +10,8 @@ crate-type = ["cdylib", "rlib"]
 [dependencies]
 prost = "0.9"
 rdkafka = { version = "0.28", features = ["ssl-vendored", "sasl"] }
-solana-logger = { version = "=1.9.5" }
-solana-accountsdb-plugin-interface = { version = "=1.9.5" }
+solana-logger = { version = "=1.8.14" }
+solana-accountsdb-plugin-interface = { version = "=1.8.14" }
 log = "0.4"
 serde_json = "1.0"
 serde = { version = "1.0", features = ["derive"] }
diff --git a/src/plugin.rs b/src/plugin.rs
index 1dacfa2..3c821dc 100644
--- a/src/plugin.rs
+++ b/src/plugin.rs
@@ -26,6 +26,10 @@ impl AccountsDbPlugin for KafkaPlugin {
         "KafkaPlugin"
     }
 
+    fn notify_end_of_startup(&mut self) -> PluginResult<()> {
+        Ok(())
+    }
+
     fn on_load(&mut self, config_file: &str) -> PluginResult<()> {
         if self.publisher.is_some() {
             let err = simple_error!("plugin already loaded");
@@ -110,14 +114,6 @@ impl AccountsDbPlugin for KafkaPlugin {
             .update_slot_status(event)
             .map_err(|e| PluginError::AccountsUpdateError { msg: e.to_string() })
     }
-
-    fn account_data_notifications_enabled(&self) -> bool {
-        self.unwrap_publisher().wants_update_account()
-    }
-
-    fn transaction_notifications_enabled(&self) -> bool {
-        false
-    }
 }
 
 impl KafkaPlugin {