Cleanup

.github/workflows/test.yml

@@ -15,13 +15,10 @@ jobs:
       - name: Check formatting
         run: sbt scalafmtCheckAll
       - name: Run unit tests
-      #TODO cleanup!  
-        run: sbt "project http4s" test
-      - name: Run kafka unit tests
-        run: sbt "project kafka" test
-#      - name: Run integration tests Kinesis
-#        run: sbt "project kinesisDistroless" IntegrationTest/test
-#      - name: Run integration tests PubSub
-#        run: sbt "project pubsubDistroless" IntegrationTest/test
+        run: sbt test
+      - name: Run integration tests Kinesis
+        run: sbt "project kinesisDistroless" IntegrationTest/test
+      - name: Run integration tests PubSub
+        run: sbt "project pubsubDistroless" IntegrationTest/test
       - name: Run integration tests Kafka
         run: sbt "project kafkaDistroless" IntegrationTest/test

kinesis/src/it/resources/collector-custom-paths.hocon

@@ -27,7 +27,7 @@ collector {
       }
 
       maxBytes = ${MAX_BYTES}
-    }}
+    }
   }
 
   "paths": {

kinesis/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/KinesisConfigSpec.scala

@@ -79,7 +79,6 @@ class KinesisConfigSpec extends Specification with CatsEffect {
   private def assert(resource: String, expectedResult: Either[ExitCode, Config[KinesisSinkConfig]]) = {
     val path = Paths.get(getClass.getResource(resource).toURI)
     ConfigParser.fromPath[IO, KinesisSinkConfig](Some(path)).value.map { result =>
-      println(result)
       result must beEqualTo(expectedResult)
     }
   }