Sha256: a4497dd709d23917df810fd63019c2fd1acd60334a58a7bb6a87dc6e50e61fa6
Contents?: true
Size: 1.17 KB
Versions: 8
Compression:
Stored size: 1.17 KB
Contents
# This patch is released under the 2-clause BSD license, same as librdkafka
# Fixes: https://github.com/confluentinc/librdkafka/issues/4783
#
--- librdkafka_2.5.0/src/rdkafka_sticky_assignor.c 2024-07-08 09:47:43.000000000 +0200
+++ librdkafka_2.5.0/src/rdkafka_sticky_assignor.c 2024-07-30 09:44:38.529759640 +0200
@@ -769,7 +769,7 @@
const rd_kafka_topic_partition_list_t *partitions;
const char *consumer;
const rd_map_elem_t *elem;
- int i;
+ int i, j;
/* The assignment is balanced if minimum and maximum numbers of
* partitions assigned to consumers differ by at most one. */
@@ -836,9 +836,9 @@
/* Otherwise make sure it can't get any more partitions */
- for (i = 0; i < potentialTopicPartitions->cnt; i++) {
+ for (j = 0; j < potentialTopicPartitions->cnt; j++) {
const rd_kafka_topic_partition_t *partition =
- &potentialTopicPartitions->elems[i];
+ &potentialTopicPartitions->elems[j];
const char *otherConsumer;
int otherConsumerPartitionCount;
Version data entries
8 entries across 8 versions & 2 rubygems