From d0345666a2399249014fad4dc582567fce430453 Mon Sep 17 00:00:00 2001 From: Kartik Naik Date: Thu, 25 Jun 2026 14:43:17 +0530 Subject: [PATCH 1/3] [KIP-932] use int64 for offset count in share ack commit offsets list --- src/rdkafka_share_acknowledgement.c | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/rdkafka_share_acknowledgement.c b/src/rdkafka_share_acknowledgement.c index 35b50d3a57..b093d9bd4f 100644 --- a/src/rdkafka_share_acknowledgement.c +++ b/src/rdkafka_share_acknowledgement.c @@ -1130,14 +1130,13 @@ rd_kafka_share_build_partition_offsets_list( rd_kafka_share_partition_offsets_list_t *list; rd_kafka_share_partition_offsets_t *elem; rd_kafka_share_ack_batch_entry_t *entry; - int total_offsets = 0; - int offset_idx = 0; + int64_t total_offsets = 0; + int64_t offset_idx = 0; int j; /* Count total offsets */ RD_LIST_FOREACH(entry, &batches->entries, j) { - total_offsets += - (int)(entry->end_offset - entry->start_offset + 1); + total_offsets += entry->end_offset - entry->start_offset + 1; } list = rd_kafka_share_partition_offsets_list_new(1); From 377f794cb850ec0cc01f53f3fb3272964d946a25 Mon Sep 17 00:00:00 2001 From: Kartik Naik Date: Sat, 4 Jul 2026 10:11:12 +0530 Subject: [PATCH 2/3] Re-run CLA check From 5a864c219c36bd24e1e4ac45842a2d45d173e777 Mon Sep 17 00:00:00 2001 From: Kartik Naik Date: Fri, 17 Jul 2026 21:51:30 +0530 Subject: [PATCH 3/3] Re-run CLA status check