From 0bfbf67d9080b999b449a9440f70021efa1d6b4c Mon Sep 17 00:00:00 2001 From: jainruchir Date: Fri, 17 Mar 2023 16:05:22 +0530 Subject: [PATCH] dev_KIP430 branch merged --- src/rdkafka_admin.c | 27 +-------------------------- 1 file changed, 1 insertion(+), 26 deletions(-) diff --git a/src/rdkafka_admin.c b/src/rdkafka_admin.c index 25b3f0fba6..485c0d8821 100644 --- a/src/rdkafka_admin.c +++ b/src/rdkafka_admin.c @@ -6053,7 +6053,7 @@ rd_list_t* rd_kafka_AuthorizedOperations_parse(int32_t authorized_operations){ for(i=0; i> i) & 1; if(bit){ - entry = malloc(sizeof(rd_kafka_AclOperation_t)); + entry = rd_malloc(sizeof(rd_kafka_AclOperation_t)); *entry = i; rd_list_add(authorized_operations_list, entry); } @@ -6457,31 +6457,6 @@ static rd_kafka_resp_err_t rd_kafka_admin_DescribeConsumerGroupsRequest( return RD_KAFKA_RESP_ERR_NO_ERROR; } -/** - * @brief Parse authorized_operations returned in - * - DescribeConsumerGroups - * - DescribeTopics - * - DescribeCluster - * @returns list of acl operations - */ -rd_list_t* rd_kafka_AuthorizedOperations_parse(int32_t authorized_operations){ - int i, bit; - rd_list_t* authorized_operations_list = NULL; - rd_kafka_AclOperation_t* entry; - /* in case of authorized_operations not requested, return NULL*/ - if(authorized_operations<0) - return NULL; - authorized_operations_list = rd_list_new(0, rd_free); - for(i=0; i> i) & 1; - if(bit){ - entry = rd_malloc(sizeof(rd_kafka_AclOperation_t)); - *entry = i; - rd_list_add(authorized_operations_list, entry); - } - } - return authorized_operations_list; -} /** * @brief Parse DescribeConsumerGroupsResponse and create ADMIN_RESULT op. */