Fixed the missing sink registration for AWS Kinesis and SQS

noctarius · Jul 4, 2023 · 35fcd99 · 35fcd99
1 parent 59a636f
commit 35fcd99
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/streamer.go b/internal/streamer.go
@@ -30,6 +30,8 @@ import (
  _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/namingstrategies"
 
  // Register built-in sinks
+ _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/sinks/awskinesis"
+ _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/sinks/awssqs"
  _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/sinks/kafka"
  _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/sinks/nats"
  _ "github.com/noctarius/timescaledb-event-streamer/internal/eventing/sinks/redis"