Merge remote-tracking branch 'origin/main' into develop

marle3003 · marle3003 · commit fec31c829302 · 2025-12-17T09:51:16.000+01:00
diff --git a/kafka/protocol.go b/kafka/protocol.go
@@ -190,8 +190,8 @@ func getTag(f reflect.StructField) kafkaTag {
 			case "nullable":
 				if len(kv) == 1 {
 					t.nullable = 0
-				} else if i, err := strconv.Atoi(kv[1]); err == nil {
-					t.nullable = int16(i)
+				} else if parsed, err := strconv.ParseInt(kv[1], 10, 16); err == nil {
+					t.nullable = int16(parsed)
 				}
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -190,8 +190,8 @@ func getTag(f reflect.StructField) kafkaTag {`
`190`	`190`	`case "nullable":`
`191`	`191`	`if len(kv) == 1 {`
`192`	`192`	`t.nullable = 0`
`193`		`- } else if i, err := strconv.Atoi(kv[1]); err == nil {`
`194`		`- t.nullable = int16(i)`
	`193`	`+ } else if parsed, err := strconv.ParseInt(kv[1], 10, 16); err == nil {`
	`194`	`+ t.nullable = int16(parsed)`
`195`	`195`	`}`
`196`	`196`	`}`
`197`	`197`	`}`