Update librdkafka to v2.5.0

Author: Gordon-F

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "rdkafka-sys"
-version = "4.7.0+2.3.0"
+version = "4.8.0+2.5.0"
 authors = ["Federico Giraud <giraud.federico@gmail.com>"]
 build = "build.rs"
 links = "rdkafka"

rdkafka-sys/Cargo.toml

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+* Upgrade to librdkafka v2.5.0.
+
 ## v4.7.0+2.2.0 (2023-11-07)
 
 * Upgrade to librdkafka v2.3.0.

rdkafka-sys/changelog.md

@@ -1,9 +1,9 @@
-/* automatically generated by rust-bindgen 0.66.1 */
+/* automatically generated by rust-bindgen 0.69.4 */
 
 use libc::{c_char, c_int, c_void, sockaddr, FILE};
 use num_enum::TryFromPrimitive;
 
-pub const RD_KAFKA_VERSION: i32 = 33751295;
+pub const RD_KAFKA_VERSION: i32 = 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: i32 = 8;
 pub const RD_KAFKA_OFFSET_BEGINNING: i32 = -2;
@@ -214,6 +214,7 @@ pub enum rd_kafka_resp_err_t {
     RD_KAFKA_RESP_ERR__NOOP = -141,
     RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET = -140,
     RD_KAFKA_RESP_ERR__LOG_TRUNCATION = -139,
+    RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD = -138,
     RD_KAFKA_RESP_ERR__END = -100,
     RD_KAFKA_RESP_ERR_UNKNOWN = -1,
     RD_KAFKA_RESP_ERR_NO_ERROR = 0,
@@ -314,7 +315,14 @@ pub enum rd_kafka_resp_err_t {
     RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION = 95,
     RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED = 96,
     RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97,
-    RD_KAFKA_RESP_ERR_END_ALL = 98,
+    RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID = 100,
+    RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH = 110,
+    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_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)]
@@ -604,6 +612,9 @@ extern "C" {
 extern "C" {
     pub fn rd_kafka_message_errstr(rkmessage: *const rd_kafka_message_t) -> *const c_char;
 }
+extern "C" {
+    pub fn rd_kafka_message_produce_errstr(rkmessage: *const rd_kafka_message_t) -> *const c_char;
+}
 extern "C" {
     pub fn rd_kafka_message_timestamp(
         rkmessage: *const rd_kafka_message_t,
@@ -1500,6 +1511,11 @@ extern "C" {
         group_instance_id: *const c_char,
     ) -> *mut rd_kafka_consumer_group_metadata_t;
 }
+extern "C" {
+    pub fn rd_kafka_consumer_group_metadata_member_id(
+        group_metadata: *const rd_kafka_consumer_group_metadata_t,
+    ) -> *const c_char;
+}
 extern "C" {
     pub fn rd_kafka_consumer_group_metadata_destroy(arg1: *mut rd_kafka_consumer_group_metadata_t);
 }
@@ -3604,6 +3620,15 @@ extern "C" {
         hi: i64,
     ) -> rd_kafka_resp_err_t;
 }
+extern "C" {
+    pub fn rd_kafka_mock_partition_push_leader_response(
+        mcluster: *mut rd_kafka_mock_cluster_t,
+        topic: *const c_char,
+        partition: c_int,
+        leader_id: i32,
+        leader_epoch: i32,
+    ) -> rd_kafka_resp_err_t;
+}
 extern "C" {
     pub fn rd_kafka_mock_broker_set_down(
         mcluster: *mut rd_kafka_mock_cluster_t,
@@ -3661,6 +3686,12 @@ pub type rd_kafka_mock_request_t = rd_kafka_mock_request_s;
 extern "C" {
     pub fn rd_kafka_mock_request_destroy(mreq: *mut rd_kafka_mock_request_t);
 }
+extern "C" {
+    pub fn rd_kafka_mock_request_destroy_array(
+        mreqs: *mut *mut rd_kafka_mock_request_t,
+        mreq_cnt: usize,
+    );
+}
 extern "C" {
     pub fn rd_kafka_mock_request_id(mreq: *mut rd_kafka_mock_request_t) -> i32;
 }
@@ -3679,3 +3710,16 @@ extern "C" {
 extern "C" {
     pub fn rd_kafka_mock_clear_requests(mcluster: *mut rd_kafka_mock_cluster_t);
 }
+extern "C" {
+    pub fn rd_kafka_mock_telemetry_set_requested_metrics(
+        mcluster: *mut rd_kafka_mock_cluster_t,
+        metrics: *mut *mut c_char,
+        metrics_cnt: usize,
+    ) -> rd_kafka_resp_err_t;
+}
+extern "C" {
+    pub fn rd_kafka_mock_telemetry_set_push_interval(
+        mcluster: *mut rd_kafka_mock_cluster_t,
+        push_interval_ms: i64,
+    ) -> rd_kafka_resp_err_t;
+}

rdkafka-sys/librdkafka

@@ -174,5 +174,13 @@ pub fn rd_kafka_resp_err_t_to_rdkafka_error(err: RDKafkaRespErr) -> RDKafkaError
         RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE => PrincipalDeserializationFailure,
         RD_KAFKA_RESP_ERR_END_ALL => EndAll,
         RD_KAFKA_RESP_ERR__LOG_TRUNCATION => LogTruncation,
+        RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD => InvalidDifferentRecord,
+        RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID => UnknownTopicId,
+        RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH => FencedMemberEpoch,
+        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,
     }
 }

rdkafka-sys/src/bindings.rs

@@ -246,6 +246,9 @@ pub enum RDKafkaErrorCode {
     AutoOffsetReset = -140,
     /// Partition log truncation detected
     LogTruncation = -139,
+    /// A different record in the batch was invalid and this message failed
+    /// persisting.
+    InvalidDifferentRecord = -138,
     #[doc(hidden)]
     End = -100,
     /// Unknown broker error.
@@ -453,6 +456,23 @@ pub enum RDKafkaErrorCode {
     FeatureUpdateFailed = 96,
     /// Request principal deserialization failed during forwarding.
     PrincipalDeserializationFailure = 97,
+    /// Unknown topic ID.
+    UnknownTopicId = 100,
+    /// The member epoch is fenced by the group coordinator.
+    FencedMemberEpoch = 110,
+    /// The instance ID is still used by another member in the consumer group.
+    UnreleasedInstanceId = 111,
+    /// The assignor or its version range is not supported by the consumer
+    /// group.
+    UnsupportedAssignor = 112,
+    /// The member epoch is stale.
+    StaleMemberEpoch = 113,
+    /// Client sent a push telemetry request with an invalid or outdated
+    /// subscription ID.
+    UnknownSubscriptionId = 117,
+    /// Client sent a push telemetry request larger than the maximum size
+    /// the broker will accept.
+    TelemetryTooLarge = 118,
     #[doc(hidden)]
     EndAll,
 }