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
 	}
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
 		}