Use correct sqs buffer queue name with Kinesis bad sink (close #393)

snowplow · Nov 9, 2023 · 23e0c42 · 23e0c42
1 parent 24a899b
commit 23e0c42
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/KinesisCollector.scala b/...c/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/KinesisCollector.scala
@@ -26,7 +26,7 @@ object KinesisCollector extends App[KinesisSinkConfig](BuildInfo) {
     val threadPoolExecutor = buildExecutorService(config.good.config)
     for {
       good <- KinesisSink.create[IO](config.good, config.good.config.sqsGoodBuffer, threadPoolExecutor)
-      bad  <- KinesisSink.create[IO](config.bad, config.good.config.sqsBadBuffer, threadPoolExecutor)
+      bad  <- KinesisSink.create[IO](config.bad, config.bad.config.sqsBadBuffer, threadPoolExecutor)
     } yield Sinks(good, bad)
   }