From 72634c97b495d1bab1a3f9b57b7d5341e4da9bde Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Fri, 13 Dec 2024 17:24:46 -0800
Subject: [PATCH] More.

---
 processes/consumer/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/processes/consumer/kafka.go b/processes/consumer/kafka.go
index 8da10aa6..b86d4aac 100644
--- a/processes/consumer/kafka.go
+++ b/processes/consumer/kafka.go
@@ -103,7 +103,7 @@ func StartConsumer(ctx context.Context, cfg config.Config, inMemDB *models.Datab
 					TopicToConfigFormatMap: tcFmtMap,
 				}
 
-				if len(msg.Key()) == 0 {
+				if len(msg.Key()) == 0 || string(msg.Key()) == "" {
 					slog.Warn("Message does not have a key", artie.KafkaMsgLogFields(kafkaMsg)...)
 					continue
 				}