From cf644dab4a3f966b8ca13ccfd6408278bb7618a0 Mon Sep 17 00:00:00 2001 From: 2pk03 Date: Sat, 17 Jan 2026 16:13:31 +0100 Subject: [PATCH 1/2] Fix int32 conversion in S3 partitions --- addons/processors/sql-processor/internal/metadata/metadata.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/addons/processors/sql-processor/internal/metadata/metadata.go b/addons/processors/sql-processor/internal/metadata/metadata.go index 955edea..e1e70e0 100644 --- a/addons/processors/sql-processor/internal/metadata/metadata.go +++ b/addons/processors/sql-processor/internal/metadata/metadata.go @@ -407,7 +407,7 @@ func (r *S3Resolver) Partitions(ctx context.Context, topic string) ([]int32, err if raw == "" { continue } - value, err := strconv.Atoi(raw) + value, err := strconv.ParseInt(raw, 10, 32) if err != nil { continue } From aa5f9457e4e6946fba9393b0dc8129a572cf41d7 Mon Sep 17 00:00:00 2001 From: 2pk03 Date: Sat, 17 Jan 2026 16:32:05 +0100 Subject: [PATCH 2/2] fix: bound partition parse for CodeQL --- addons/processors/sql-processor/internal/discovery/discovery.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/addons/processors/sql-processor/internal/discovery/discovery.go b/addons/processors/sql-processor/internal/discovery/discovery.go index ff4bcce..48e94b6 100644 --- a/addons/processors/sql-processor/internal/discovery/discovery.go +++ b/addons/processors/sql-processor/internal/discovery/discovery.go @@ -331,7 +331,7 @@ func parseSegmentKey(prefix, key string) (segmentKey, string, bool) { return segmentKey{}, "", false } topic := parts[0] - partition, err := strconv.Atoi(parts[1]) + partition, err := strconv.ParseInt(parts[1], 10, 32) if err != nil { return segmentKey{}, "", false }