CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

This commit is contained in:
Mikhail Konovalov 2024-08-30 01:05:18 +10:00 committed by GitHub
parent de24c1683c
commit 88663992e4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/outputs/kinesis/kinesis.go
View File

@ -69,6 +69,10 @@ func (k *KinesisOutput) Connect() error {
return err return err
} }
if k.EndpointURL != "" {
cfg.BaseEndpoint = &k.EndpointURL
}
svc := kinesis.NewFromConfig(cfg) svc := kinesis.NewFromConfig(cfg)
_, err = svc.DescribeStreamSummary(context.Background(), &kinesis.DescribeStreamSummaryInput{ _, err = svc.DescribeStreamSummary(context.Background(), &kinesis.DescribeStreamSummaryInput{