From de24c1683c76fd07bb63511732a92f5859d6960c Mon Sep 17 00:00:00 2001
From: Mikhail Konovalov <4463812+mskonovalov@users.noreply.github.com>
Date: Fri, 30 Aug 2024 01:04:38 +1000
Subject: [PATCH] fix(inputs.kinesis_consumer): Honor the configured endpoint
 (#15788)

---
 plugins/inputs/kinesis_consumer/kinesis_consumer.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/plugins/inputs/kinesis_consumer/kinesis_consumer.go b/plugins/inputs/kinesis_consumer/kinesis_consumer.go
index 1133c961c..a9b9a160f 100644
--- a/plugins/inputs/kinesis_consumer/kinesis_consumer.go
+++ b/plugins/inputs/kinesis_consumer/kinesis_consumer.go
@@ -94,6 +94,10 @@ func (k *KinesisConsumer) connect(ac telegraf.Accumulator) error {
 	if err != nil {
 		return err
 	}
+
+	if k.EndpointURL != "" {
+		cfg.BaseEndpoint = &k.EndpointURL
+	}
 	client := kinesis.NewFromConfig(cfg)
 
 	k.checkpoint = &noopStore{}