From 8ce9f34baed39ffd1e92f456e853d379dc9c9c5e Mon Sep 17 00:00:00 2001
From: walt-sk <walter@streamkap.com>
Date: Tue, 17 Jun 2025 14:24:10 -0400
Subject: [PATCH] fix(demo): redis-sink-json Connector failure

Swapped the converter configs for the key and value to have the Connect not fail and stream writes.
---
 run.sh | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/run.sh b/run.sh
index 15663fc..282ea86 100755
--- a/run.sh
+++ b/run.sh
@@ -96,14 +96,14 @@ curl -X POST -H "Content-Type: application/json" --data '
    "config": {
      "connector.class": "com.redis.kafka.connect.RedisSinkConnector",
      "tasks.max": "1",
-     "key.converter": "org.apache.kafka.connect.json.JsonConverter",
+     "key.converter": "org.apache.kafka.connect.storage.StringConverter",
      "redis.type": "JSON",
      "redis.uri": "redis://redis:6379",
      "topics": "pageviews",
      "transforms": "Cast",
      "transforms.Cast.spec": "string",
      "transforms.Cast.type": "org.apache.kafka.connect.transforms.Cast$Key",
-     "value.converter": "org.apache.kafka.connect.storage.StringConverter",
+     "value.converter": "org.apache.kafka.connect.json.JsonConverter",
      "value.converter.schemas.enable": "false"
 }}' http://localhost:8083/connectors -w "\n"