From a7fc26aab8bcdd36697a412070df455980c5c0e6 Mon Sep 17 00:00:00 2001 From: Saurav Kumar Date: Sat, 20 Sep 2025 19:49:07 +0530 Subject: [PATCH] fix(): fixing exception in ingestion of expired keys in keys source --- .../java/com/redis/kafka/connect/source/ToStructFunction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/ToStructFunction.java b/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/ToStructFunction.java index 084810d..01d2436 100644 --- a/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/ToStructFunction.java +++ b/core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/ToStructFunction.java @@ -39,7 +39,7 @@ public class ToStructFunction implements Function, Struct> { public static final Schema TTL_SCHEMA = Schema.OPTIONAL_INT64_SCHEMA; - public static final Schema TYPE_SCHEMA = Schema.STRING_SCHEMA; + public static final Schema TYPE_SCHEMA = Schema.OPTIONAL_STRING_SCHEMA; public static final String VALUE_SCHEMA_NAME = "com.redis.kafka.connect.keys.Value";