From 88663992e454ee31b42cbfb6693fa81ab38cf752 Mon Sep 17 00:00:00 2001
From: Mikhail Konovalov <4463812+mskonovalov@users.noreply.github.com>
Date: Fri, 30 Aug 2024 01:05:18 +1000
Subject: [PATCH] fix(outputs.kinesis): Honor the configured endpoint (#15781)

---
 plugins/outputs/kinesis/kinesis.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/plugins/outputs/kinesis/kinesis.go b/plugins/outputs/kinesis/kinesis.go
index 340edca60..24b362204 100644
--- a/plugins/outputs/kinesis/kinesis.go
+++ b/plugins/outputs/kinesis/kinesis.go
@@ -69,6 +69,10 @@ func (k *KinesisOutput) Connect() error {
 		return err
 	}
 
+	if k.EndpointURL != "" {
+		cfg.BaseEndpoint = &k.EndpointURL
+	}
+
 	svc := kinesis.NewFromConfig(cfg)
 
 	_, err = svc.DescribeStreamSummary(context.Background(), &kinesis.DescribeStreamSummaryInput{