Merge branch 'main' into reuse-deser

swimos · Dec 11, 2024 · 3217459 · 3217459
2 parents 34862a0 + c3e09d6
commit 3217459
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -134,7 +134,7 @@ tracing-subscriber = "0.3"
 tracing-appender = "0.2"
 base64 = "0.22"
 num-traits = "0.2"
-thiserror = "1.0"
+thiserror = "2.0"
 static_assertions = "1.1.0"
 url = "2.1.1"
 chrono = "0.4.31"
@@ -186,8 +186,8 @@ num = "0.4"
 smol_str = "0.3.1"
 http-body-util = "0.1.2"
 hyper-util = "0.1.5"
-rdkafka = "0.36"
+rdkafka = "0.37"
 apache-avro = "0.17.0"
 time = "0.3.36"
 rumqttc = "0.24.0"
-fluvio = "0.23.2"
+fluvio = "0.24.0"
diff --git a/server/swimos_connector_kafka/src/facade.rs b/server/swimos_connector_kafka/src/facade.rs
@@ -20,6 +20,7 @@ use std::{
 
 use crate::config::KafkaLogLevel;
 use futures::{Future, FutureExt};
+use rdkafka::consumer::BaseConsumer;
 use rdkafka::{
     config::RDKafkaLogLevel,
     consumer::{CommitMode, Consumer, ConsumerContext, Rebalance, StreamConsumer},
@@ -146,11 +147,11 @@ impl ClientContext for KafkaClientContext {
 }
 
 impl ConsumerContext for KafkaClientContext {
-    fn pre_rebalance(&self, rebalance: &Rebalance) {
+    fn pre_rebalance(&self, _base_consumer: &BaseConsumer<Self>, rebalance: &Rebalance) {
         info!("Pre rebalance {:?}", rebalance);
     }
 
-    fn post_rebalance(&self, rebalance: &Rebalance) {
+    fn post_rebalance(&self, _base_consumer: &BaseConsumer<Self>, rebalance: &Rebalance) {
         info!("Post rebalance {:?}", rebalance);
     }