fix(converter): ignore case for writer name

Signed-off-by: Jiyong Huang <[email protected]>
lf-edge · Mar 3, 2025 · 1709a25 · 1709a25
1 parent ba1b80a
commit 1709a25
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/internal/converter/converter.go b/internal/converter/converter.go
@@ -66,10 +66,12 @@ func GetOrCreateConverter(ctx api.StreamContext, format string, schemaId string,
 }
 
 func GetConvertWriter(ctx api.StreamContext, format string, schemaId string, schema map[string]*ast.JsonStreamField, props map[string]any) (message.ConvertWriter, error) {
-	if cw, ok := modules.ConvertWriters[format]; ok {
+	t := strings.ToLower(format)
+	if cw, ok := modules.ConvertWriters[t]; ok {
+		ctx.GetLogger().Infof("writer %s not found, fall back to stack writer", t)
 		return cw(ctx, schemaId, schema, props)
 	}
-	c, err := GetOrCreateConverter(ctx, format, schemaId, schema, props)
+	c, err := GetOrCreateConverter(ctx, t, schemaId, schema, props)
 	if err != nil {
 		return nil, err
 	}