Skip to content

Commit

Permalink
Fix typo in result type
Browse files Browse the repository at this point in the history
  • Loading branch information
milindl committed Sep 6, 2023
1 parent e6d4d63 commit 0233c0f
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
8 changes: 4 additions & 4 deletions src/rdkafka.h
Original file line number Diff line number Diff line change
Expand Up @@ -8234,7 +8234,7 @@ void rd_kafka_DescribeCluster(rd_kafka_t *rk,
*/
RD_EXPORT
const rd_kafka_Node_t **rd_kafka_DescribeCluster_result_nodes(
const rd_kafka_DescribeTopics_result_t *result,
const rd_kafka_DescribeCluster_result_t *result,
size_t *cntp);

/**
Expand All @@ -8250,7 +8250,7 @@ const rd_kafka_Node_t **rd_kafka_DescribeCluster_result_nodes(
RD_EXPORT
const rd_kafka_AclOperation_t *
rd_kafka_DescribeCluster_result_authorized_operations(
const rd_kafka_DescribeTopics_result_t *result,
const rd_kafka_DescribeCluster_result_t *result,
size_t *cntp);

/**
Expand All @@ -8262,7 +8262,7 @@ rd_kafka_DescribeCluster_result_authorized_operations(
*/
RD_EXPORT
const rd_kafka_Node_t *rd_kafka_DescribeCluster_result_controller(
const rd_kafka_DescribeTopics_result_t *result);
const rd_kafka_DescribeCluster_result_t *result);

/**
* @brief Gets the cluster id for the \p result cluster.
Expand All @@ -8275,7 +8275,7 @@ const rd_kafka_Node_t *rd_kafka_DescribeCluster_result_controller(
*/
RD_EXPORT
const char *rd_kafka_DescribeCluster_result_cluster_id(
const rd_kafka_DescribeTopics_result_t *result);
const rd_kafka_DescribeCluster_result_t *result);

/**@}*/

Expand Down
10 changes: 5 additions & 5 deletions src/rdkafka_admin.c
Original file line number Diff line number Diff line change
Expand Up @@ -8307,7 +8307,7 @@ void rd_kafka_DescribeTopics(rd_kafka_t *rk,

static const rd_kafka_ClusterDescription_t *
rd_kafka_DescribeCluster_result_description(
const rd_kafka_DescribeTopics_result_t *result) {
const rd_kafka_DescribeCluster_result_t *result) {
int cluster_result_cnt;
const rd_kafka_ClusterDescription_t *clusterdesc;
const rd_kafka_op_t *rko = (const rd_kafka_op_t *)result;
Expand All @@ -8324,7 +8324,7 @@ rd_kafka_DescribeCluster_result_description(


const rd_kafka_Node_t **rd_kafka_DescribeCluster_result_nodes(
const rd_kafka_DescribeTopics_result_t *result,
const rd_kafka_DescribeCluster_result_t *result,
size_t *cntp) {
const rd_kafka_ClusterDescription_t *clusterdesc =
rd_kafka_DescribeCluster_result_description(result);
Expand All @@ -8334,7 +8334,7 @@ const rd_kafka_Node_t **rd_kafka_DescribeCluster_result_nodes(

const rd_kafka_AclOperation_t *
rd_kafka_DescribeCluster_result_authorized_operations(
const rd_kafka_DescribeTopics_result_t *result,
const rd_kafka_DescribeCluster_result_t *result,
size_t *cntp) {
const rd_kafka_ClusterDescription_t *clusterdesc =
rd_kafka_DescribeCluster_result_description(result);
Expand All @@ -8343,12 +8343,12 @@ rd_kafka_DescribeCluster_result_authorized_operations(
}

const char *rd_kafka_DescribeCluster_result_cluster_id(
const rd_kafka_DescribeTopics_result_t *result) {
const rd_kafka_DescribeCluster_result_t *result) {
return rd_kafka_DescribeCluster_result_description(result)->cluster_id;
}

const rd_kafka_Node_t *rd_kafka_DescribeCluster_result_controller(
const rd_kafka_DescribeTopics_result_t *result) {
const rd_kafka_DescribeCluster_result_t *result) {
return rd_kafka_DescribeCluster_result_description(result)->controller;
}

Expand Down

0 comments on commit 0233c0f

Please sign in to comment.