Upgrade to librdkafka v2.5

MaterializeInc · Aug 31, 2024 · 4a217ec · 4a217ec
1 parent 7462dc2
commit 4a217ec
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/rdkafka-sys/Cargo.toml b/rdkafka-sys/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "rdkafka-sys"
-version = "4.3.0+2.4.0"
+version = "4.3.0+2.5.0"
 authors = ["Federico Giraud <[email protected]>"]
 build = "build.rs"
 links = "rdkafka"

diff --git a/rdkafka-sys/librdkafka b/rdkafka-sys/librdkafka
diff --git a/rdkafka-sys/src/bindings.rs b/rdkafka-sys/src/bindings.rs
@@ -3,7 +3,7 @@
 use libc::{addrinfo, c_char, c_int, c_void, sockaddr, FILE};
 use num_enum::TryFromPrimitive;
 
-pub const RD_KAFKA_VERSION: u32 = 33816831;
+pub const RD_KAFKA_VERSION: u32 = 33882367;
 pub const RD_KAFKA_DEBUG_CONTEXTS : & [u8 ; 138] = b"all,generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf\0" ;
 pub const RD_KAFKA_DESTROY_F_NO_CONSUMER_CLOSE: u32 = 8;
 pub const RD_KAFKA_OFFSET_BEGINNING: i32 = -2;
@@ -320,7 +320,9 @@ pub enum rd_kafka_resp_err_t {
     RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID = 111,
     RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR = 112,
     RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH = 113,
-    RD_KAFKA_RESP_ERR_END_ALL = 114,
+    RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID = 117,
+    RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE = 118,
+    RD_KAFKA_RESP_ERR_END_ALL = 119,
 }
 #[repr(C)]
 #[derive(Debug, Copy, Clone)]

diff --git a/rdkafka-sys/src/helpers.rs b/rdkafka-sys/src/helpers.rs
@@ -179,6 +179,8 @@ pub fn rd_kafka_resp_err_t_to_rdkafka_error(err: RDKafkaRespErr) -> RDKafkaError
         RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID => UnreleasedInstanceId,
         RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR => UnsupportedAssignor,
         RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH => StaleMemberEpoch,
+        RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID => UnknownSubscriptionId,
+        RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE => TelemetryTooLarge,
         RD_KAFKA_RESP_ERR_END_ALL => EndAll,
     }
 }
diff --git a/rdkafka-sys/src/types.rs b/rdkafka-sys/src/types.rs
@@ -459,6 +459,12 @@ pub enum RDKafkaErrorCode {
     UnsupportedAssignor = 112,
     /// The member epoch is stale.
     StaleMemberEpoch = 113,
+    /// The client sent a push telemetry request with an invalid or outdated
+    /// subscription ID.
+    UnknownSubscriptionId = 117,
+    /// The client sent a push telemetry request larger than the maximum size
+    /// that the broker will accept.
+    TelemetryTooLarge = 118,
     #[doc(hidden)]
     EndAll,
 }