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

fix(inputs.kinesis_consumer): Honor the configured endpoint (#15788)

This commit is contained in:
Mikhail Konovalov 2024-08-30 01:04:38 +10:00 committed by GitHub
parent f693df81d3
commit de24c1683c
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/inputs/kinesis_consumer/kinesis_consumer.go
View File

@ -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{}