update notification type field name

zalbiraw · Nov 29, 2024 · 3311f81 · 3311f81
1 parent 039f2b3
commit 3311f81
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/services/kafka/notifications/helpers/Notificaiton.go b/services/kafka/notifications/helpers/Notificaiton.go
@@ -64,7 +64,7 @@ func GetRandomNotification() interface{} {
 
 	// Return the map that matches Avro schema
 	return map[string]interface{}{
-		"notificationType": notificationType,
-		"msg":              msg,
+		"type": notificationType,
+		"msg":  msg,
 	}
 }
diff --git a/services/kafka/notifications/producer.go b/services/kafka/notifications/producer.go
@@ -99,10 +99,10 @@ func getCodec() *goavro.Codec {
 		"name": "Notification",
 		"fields": [
 			{
-				"name": "notificationType",
+				"name": "type",
 				"type": {
 					"type": "enum",
-					"name": "NotificationType",
+					"name": "type",
 					"symbols": ["LIKE", "SHARE", "COMMENT"]
 				}
 			},