From ada48be181623019a4c8fb720c2b1432464a901a Mon Sep 17 00:00:00 2001
From: Jacob Brinlee <66123601+jrbrinlee1@users.noreply.github.com>
Date: Thu, 16 Mar 2023 09:16:31 -0500
Subject: [PATCH] check for valid name in kafka-config (#2321)

---
 cli/kafka/config.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/cli/kafka/config.go b/cli/kafka/config.go
index 582b8ea2d..444d0642f 100644
--- a/cli/kafka/config.go
+++ b/cli/kafka/config.go
@@ -67,6 +67,9 @@ func ValidateConfig(c Config) error {
 				if c.Fields[i].PrimaryKey {
 					found++
 				}
+				if c.Fields[i].Name == "" {
+					return errors.Errorf("a name attribute (which isn't equal to \"\") should exist for all fields")
+				}
 			}
 			if found != 1 {
 				return errors.Errorf("exactly one primary key field is required")