More.

artie-labs · Dec 14, 2024 · 72634c9 · 72634c9
1 parent 14bc747
commit 72634c9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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
 				}