Is there an example of refreshing msk_iam keys when they expire?

[teeterc]

I'm new to go so I apologize if this is obvious.

I'm using a a block like this to connect to a serverless MSK instance and I'm running into issues when the keys expire.

slog.Info("using sasl")
		cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithRegion(kafkaConfig.AWSRegion))
		if err != nil {
			log.Fatalf("unable to load SDK config, %v", err)
		}

		if err != nil {
			return nil, err
		}

		// TODO: Understand how to make this get a new key when it expires
		mechanism := &aws_msk_iam_v2.Mechanism{
			Signer:      signer.NewSigner(),
			Credentials: cfg.Credentials,
			Region:      kafkaConfig.AWSRegion,
			SignTime:    time.Now(),
			Expiry:      time.Minute * 5,
		}

Is there something that i can set that will tell the transport to generate a new key when the keys expire?

Thanks!

[teeterc]

To follow up on on this: The issue with the keys not refreshing was that I was setting an absolute sign time.

SignTime:    time.Now(),
Expiry:      time.Minute * 5