fix(outputs.kinesis): Honor the configured endpoint (influxdata#15781)

asaharn · Oct 16, 2024 · b3ed628 · b3ed628
1 parent 51e4503
commit b3ed628
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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{