adapters/wredis: Add streamer and support container tests

.github/workflows/tests.yml

@@ -49,4 +49,33 @@ jobs:
           find ./_examples -type f -name "go.mod" -exec dirname {} \; | while read -r dir; do
             echo "Running go vet in $dir"
             (cd "$dir" && go vet ./...)
-          done
+          done
+
+  integration_tests:
+    name: Integration Tests (Testcontainers)
+    runs-on: ubuntu-latest
+    timeout-minutes: 15
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version-file: 'go.mod'
+
+      - name: Check Docker availability
+        run: |
+          docker --version
+          docker info
+
+      - name: Test Kafka Adapter with Testcontainers
+        run: |
+          cd ./adapters/kafkastreamer
+          echo "🚀 Testing Kafka adapter with testcontainers..."
+          go test -v -timeout=10m ./...
+
+      - name: Test Redis Adapter with Testcontainers
+        run: |
+          cd ./adapters/wredis
+          echo "🚀 Testing Redis adapter with testcontainers..."
+          go test -v -timeout=10m ./...