From e48142e7c776d97c0953205303a2860d5ffb05be Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Tue, 10 Dec 2024 10:35:25 +0000 Subject: [PATCH 1/3] Update rdkafka requirement from 0.36 to 0.37 Updates the requirements on [rdkafka](https://github.com/fede1024/rust-rdkafka) to permit the latest version. - [Changelog](https://github.com/fede1024/rust-rdkafka/blob/master/changelog.md) - [Commits](https://github.com/fede1024/rust-rdkafka/compare/v0.36.0...v0.36.2) --- updated-dependencies: - dependency-name: rdkafka dependency-type: direct:production ... Signed-off-by: dependabot[bot] --- Cargo.toml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 4f6f4bbd9..a8b756c0e 100644 --- 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" From 53396910beeacc2c7ba9d968b51a9041722b15d4 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Wed, 11 Dec 2024 11:59:08 +0000 Subject: [PATCH 2/3] Update rdkafka requirement from 0.36 to 0.37 Updates the requirements on [rdkafka](https://github.com/fede1024/rust-rdkafka) to permit the latest version. - [Changelog](https://github.com/fede1024/rust-rdkafka/blob/master/changelog.md) - [Commits](https://github.com/fede1024/rust-rdkafka/compare/v0.36.0...v0.36.2) --- updated-dependencies: - dependency-name: rdkafka dependency-type: direct:production ... Signed-off-by: dependabot[bot] --- Cargo.toml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 1ca2daa08..f997800fb 100644 --- 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" From c790d59cd6b301060a11dbd983124117f0449d6c Mon Sep 17 00:00:00 2001 From: SirCipher Date: Wed, 11 Dec 2024 12:01:18 +0000 Subject: [PATCH 3/3] Updates to new rdkafka API --- server/swimos_connector_kafka/src/facade.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/server/swimos_connector_kafka/src/facade.rs b/server/swimos_connector_kafka/src/facade.rs index a84f0ad07..7c8d6b17a 100644 --- 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, rebalance: &Rebalance) { info!("Pre rebalance {:?}", rebalance); } - fn post_rebalance(&self, rebalance: &Rebalance) { + fn post_rebalance(&self, _base_consumer: &BaseConsumer, rebalance: &Rebalance) { info!("Post rebalance {:?}", rebalance); }