We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e5213f7 commit 0fcfb97Copy full SHA for 0fcfb97
src/aws/flb_aws_msk_iam.c
@@ -606,13 +606,13 @@ struct flb_aws_msk_iam *flb_aws_msk_iam_register_oauth_cb(struct flb_config *con
606
ctx->flb_config = config;
607
608
/* Extract region from broker address */
609
- if (!opaque || !opaque->kafka_ctx) {
+ if (!opaque || !opaque->ptr) {
610
flb_error("[aws_msk_iam] unable to access kafka context for broker-based region extraction");
611
flb_free(ctx);
612
return NULL;
613
}
614
615
- kafka_ctx = opaque->kafka_ctx;
+ kafka_ctx = (struct flb_kafka *) opaque->ptr;
616
if (!kafka_ctx->brokers || flb_sds_len(kafka_ctx->brokers) == 0) {
617
flb_error("[aws_msk_iam] brokers configuration is required for region extraction");
618
0 commit comments