Merge pull request #745 from swimos/dependabot/cargo/rdkafka-0.37

dependabot[bot] · web-flow · commit c3e09d69b9a7 · 2024-12-11T13:19:00.000Z
diff --git a/Cargo.toml b/Cargo.toml
@@ -186,7 +186,7 @@ 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"
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);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -20,6 +20,7 @@ use std::{`
`20`	`20`
`21`	`21`	`use crate::config::KafkaLogLevel;`
`22`	`22`	`use futures::{Future, FutureExt};`
	`23`	`+use rdkafka::consumer::BaseConsumer;`
`23`	`24`	`use rdkafka::{`
`24`	`25`	`config::RDKafkaLogLevel,`
`25`	`26`	`consumer::{CommitMode, Consumer, ConsumerContext, Rebalance, StreamConsumer},`
`@@ -146,11 +147,11 @@ impl ClientContext for KafkaClientContext {`
`146`	`147`	`}`
`147`	`148`
`148`	`149`	`impl ConsumerContext for KafkaClientContext {`
`149`		`- fn pre_rebalance(&self, rebalance: &Rebalance) {`
	`150`	`+ fn pre_rebalance(&self, _base_consumer: &BaseConsumer<Self>, rebalance: &Rebalance) {`
`150`	`151`	`info!("Pre rebalance {:?}", rebalance);`
`151`	`152`	`}`
`152`	`153`
`153`		`- fn post_rebalance(&self, rebalance: &Rebalance) {`
	`154`	`+ fn post_rebalance(&self, _base_consumer: &BaseConsumer<Self>, rebalance: &Rebalance) {`
`154`	`155`	`info!("Post rebalance {:?}", rebalance);`
`155`	`156`	`}`
`156`	`157`