From 9d5103c90540a0636dbf183738923eeab73748d1 Mon Sep 17 00:00:00 2001 From: Mikhail Date: Wed, 28 Aug 2024 10:47:03 +1000 Subject: [PATCH] feat: add endpoint to input plugin as well --- 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 1133c961ca3be..a9b9a160f9a05 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{}