From 91fd461452983089f33d9de00207119f2372499b Mon Sep 17 00:00:00 2001 From: Andrew Garrett Date: Tue, 19 Oct 2021 08:26:35 -0400 Subject: [PATCH] Removed check int and added debug --- src/rdkafka_sasl_aws_msk_iam.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/rdkafka_sasl_aws_msk_iam.c b/src/rdkafka_sasl_aws_msk_iam.c index 503131a2ef..3ac7f2b49e 100644 --- a/src/rdkafka_sasl_aws_msk_iam.c +++ b/src/rdkafka_sasl_aws_msk_iam.c @@ -349,7 +349,7 @@ rd_kafka_aws_msk_iam_credential_refresh0 ( credential->aws_region = rd_strdup(handle_aws_region); credential->md_lifetime_ms = now_wallclock_ms + conf->sasl.duration_sec * 1000; - int check = rd_kafka_aws_send_request(credential, + rd_kafka_aws_send_request(credential, ymd, hms, host, @@ -396,9 +396,11 @@ rd_kafka_aws_msk_iam_credential_refresh (rd_kafka_t *rk, void *opaque) { char errstr[512]; rd_kafka_aws_credential_t credential = RD_ZERO_INIT; - rd_kafka_dbg(rk, SECURITY, "SASLAWSMSKIAM", "Refreshing AWS credentials"); + rd_kafka_dbg(rk, SECURITY, "SASLAWSMSKIAM", "Checking to refreshing AWS credentials"); if (rk->rk_conf.sasl.enable_use_sts) { + rd_kafka_dbg(rk, SECURITY, "SASLAWSMSKIAM", "Use STS enabled, will refresh credentials"); + if (rd_kafka_aws_msk_iam_credential_refresh0( rk, &credential, rd_uclock() / 1000, errstr, sizeof(errstr)) == -1 ||