solana v1.8.14

Author: Richard Patel

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"] }

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 {