Fancy stream processing made operationally mundane
This report presents the forensic synthetic code analysis of redpanda-data/connect, a Go project with 8,727 GitHub stars. SynthScan v2.0 examined 317,303 lines of code across 1541 source files, recording 1100 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 4.2 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 1100 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | cmd/tools/plugins_csv_fmt/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/schema_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/bloblang_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/utils_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/run.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/show.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/cache_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/docker.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/packages.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/cache.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/events.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/utils.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/show_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/output.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration/main.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/integration_test_registry/main.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/serverless/connect-lambda/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect-ai/sqlite.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect-ai/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect-cloud/sqlite.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect-cloud/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect-community/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/redpanda-connect/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | licenses/Apache-2.0_header.go.txt | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | licenses/rcl_header.go.txt | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | config/examples/aws_cloudwatch_logs.yaml | 1 | # AWS CloudWatch Logs Source Connector (Confluent-compatible) | COMMENT |
| LOW | config/examples/aws_cloudwatch_logs.yaml | 21 | # start_time: "2024-01-01T00:00:00Z" | COMMENT |
| LOW | config/examples/aws_cloudwatch_logs.yaml | 81 | # Alternative: Output to stdout for testing | COMMENT |
| LOW | config/examples/stateful_polling.yaml | 81 | # generate: | COMMENT |
| LOW | resources/docker/profiling/docker-compose.yaml | 41 | # jaeger: | COMMENT |
| LOW | resources/scripts/third_party_licenses.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | internal/impl/dgraph/cache_ristretto.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/dgraph/cache_ristretto_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/chat_processor_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/embeddings_processor.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/rerank_processor_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/chat_processor.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/json_schema_provider.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/base_processor.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/cohere/rerank_processor.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/postgresql/integration_test.go | 361 | // A real process crash drops the connection, so postgres releases the | COMMENT |
| LOW | …al/impl/postgresql/bench/kafka-connector/producer.yaml | 1 | # Produces COUNT synthetic events to the bench-events Kafka topic. | COMMENT |
| LOW | …impl/postgresql/pglogicalstream/replication_message.go | 481 | // UpdateMessage is a update message. | COMMENT |
| LOW | internal/impl/postgresql/pglogicalstream/pglogrepl.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | …ernal/impl/postgresql/pglogicalstream/pgtype_compat.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | …ernal/impl/postgresql/pglogicalstream/pgtype_compat.go | 21 | // | COMMENT |
| LOW | …l/postgresql/pglogicalstream/sanitize/sanitize_test.go | 1 | // Copyright (c) 2013-2021 Jack Christensen | COMMENT |
| LOW | …l/impl/postgresql/pglogicalstream/sanitize/sanitize.go | 1 | // Copyright (c) 2013-2021 Jack Christensen | COMMENT |
| LOW | internal/impl/postgresql/aws/aws.go | 1 | // Copyright 2025 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/twitter/init.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/bcrypt_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/jwt_parse_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/jwt_sign.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/argon2_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/argon2.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/argon2.go | 41 | memory uint32 | COMMENT |
| LOW | internal/impl/crypto/jwt_sign_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/bcrypt.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | internal/impl/crypto/jwt_parse.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| 843 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | internal/impl/postgresql/bench/Taskfile.yaml | 14 | # ── PostgreSQL container ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/postgresql/bench/Taskfile.yaml | 35 | # ── Data setup ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/postgresql/bench/Taskfile.yaml | 67 | # ── CDC / Snapshot benchmarks ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/postgresql/bench/Taskfile.yaml | 117 | # ── Kafka → PostgreSQL benchmarks (vs Kafka Connect JDBC Sink) ─────────────── | COMMENT |
| MEDIUM | …l/postgresql/bench/kafka-connector/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/postgresql/bench/kafka-connector/docker-compose.yaml | 30 | # ── PostgreSQL (benchmark sink target) ─────────────────────────────────────── | COMMENT |
| MEDIUM | …l/postgresql/bench/kafka-connector/docker-compose.yaml | 46 | # ── Kafka Connect + JDBC sink plugin (built from Dockerfile) ───────────────── | COMMENT |
| MEDIUM | …l/postgresql/bench/kafka-connector/docker-compose.yaml | 78 | # ── Create bench-events Kafka topic ────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/postgresql/bench/kafka-connector/docker-compose.yaml | 96 | # ── Create bench_events table in PostgreSQL ─────────────────────────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 30 | # ── MinIO (S3-compatible object storage) ───────────────────────────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 48 | # ── Create the 'warehouse' S3 bucket ───────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 63 | # ── Iceberg REST catalog ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 86 | # ── Kafka Connect + Iceberg sink plugin (built from Dockerfile) ─────────────── | COMMENT |
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 122 | # ── Create bench-events topic and the Iceberg 'benchmark' namespace ─────────── | COMMENT |
| MEDIUM | internal/impl/mysql/bench/Taskfile.yaml | 11 | # ── MySQL container ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/mysql/bench/Taskfile.yaml | 36 | # ── Data setup ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/mysql/bench/Taskfile.yaml | 63 | # ── Benchmarks ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml | 30 | # ── MySQL (benchmark sink target) ──────────────────────────────────────────── | COMMENT |
| MEDIUM | …/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml | 45 | # ── Create bench-events Kafka topic ────────────────────────────────────────── | COMMENT |
| MEDIUM | …/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml | 63 | # ── Create bench_events table in MySQL ─────────────────────────────────────── | COMMENT |
| MEDIUM | …/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml | 30 | # ── MySQL (benchmark sink target) ──────────────────────────────────────────── | COMMENT |
| MEDIUM | …/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml | 45 | # ── Kafka Connect + JDBC sink plugin (built from Dockerfile) ───────────────── | COMMENT |
| MEDIUM | …/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml | 77 | # ── Create bench-events Kafka topic ────────────────────────────────────────── | COMMENT |
| MEDIUM | …/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml | 95 | # ── Create bench_events table in MySQL ─────────────────────────────────────── | COMMENT |
| MEDIUM | …l/impl/mysql/bench/mysql-read/rpcn/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/impl/mysql/bench/mysql-read/rpcn/docker-compose.yaml | 30 | # ── MySQL (binlog enabled — mysql_cdc source) ───────────────────────────────── | COMMENT |
| MEDIUM | …pl/mysql/bench/mysql-read/debezium/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/mysql/bench/mysql-read/debezium/docker-compose.yaml | 30 | # ── MySQL (binlog enabled — Debezium source) ───────────────────────────────── | COMMENT |
| MEDIUM | …pl/mysql/bench/mysql-read/debezium/docker-compose.yaml | 52 | # ── Kafka Connect + Debezium MySQL source plugin ────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 10 | # ── Pipeline parameters ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 16 | # ── Matrix sweep lists ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 30 | # ── Infrastructure ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 45 | # ── Pipeline lifecycle ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 92 | # ── Data management ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 112 | # ── Observation ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 129 | # ── Single parameterised run ────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml | 221 | # ── Logs ────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/aws/s3/bench/write/kafka-connect/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/aws/s3/bench/write/kafka-connect/docker-compose.yaml | 30 | # ── LocalStack (S3 sink target) ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/aws/s3/bench/write/kafka-connect/docker-compose.yaml | 46 | # ── Kafka Connect + S3 Sink plugin (built from Dockerfile) ─────────────────── | COMMENT |
| MEDIUM | …l/aws/s3/bench/write/kafka-connect/docker-compose.yaml | 86 | # ── Create bench-events Kafka topic ────────────────────────────────────────── | COMMENT |
| MEDIUM | …l/aws/s3/bench/write/kafka-connect/docker-compose.yaml | 104 | # ── Create bench-events S3 bucket in LocalStack ─────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 12 | # ── Connector parameters (used by connector:create and bench:run) ───────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 23 | # ── Matrix sweep lists (space-separated values to try for each parameter) ───── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 31 | # ── Infrastructure ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 45 | # ── Connector management ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 118 | # ── Data loading ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 138 | # ── Observation ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 241 | # ── Single parameterised run ────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 350 | # ── Matrix sweep ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml | 515 | # ── Logs ────────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml | 2 | # ── Kafka (KRaft, no ZooKeeper) ────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml | 30 | # ── LocalStack (S3 source) ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml | 46 | # ── Kafka Connect + S3 plugin ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml | 84 | # ── Create bench-events Kafka topic ────────────────────────────────────────── | COMMENT |
| MEDIUM | …pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml | 102 | # ── Create bench-events S3 bucket in LocalStack ─────────────────────────────── | COMMENT |
| MEDIUM | …nal/impl/aws/s3/bench/read/kafka-connect/Taskfile.yaml | 25 | # ── Infrastructure ──────────────────────────────────────────────────────────── | COMMENT |
| 6 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | …t/_proto/redpanda/runtime/v1alpha1/message_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | …ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 0 | client and server classes corresponding to protobuf-defined services. | STRING |
| HIGH | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 0 | init is the first method called for a batch output and it passes the user's configuration to the output. the schema for | STRING |
| HIGH | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 0 | init is the first method called for a batch output and it passes the user's configuration to the output. the schema for | STRING |
| HIGH | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 0 | init is the first method called for a batch output and it passes the user's configuration to the output. the schema for | STRING |
| HIGH | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 0 | close the component, blocks until either the underlying resources are cleaned up or the rpc deadline is reached. | STRING |
| HIGH | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 0 | close the component, blocks until either the underlying resources are cleaned up or the rpc deadline is reached. | STRING |
| HIGH | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 0 | close the component, blocks until either the underlying resources are cleaned up or the rpc deadline is reached. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 19 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 19 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 19 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 20 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 30 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 30 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 30 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 30 | CODE | |
| LOW | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 3 | CODE | |
| LOW | …onnect/_proto/redpanda/runtime/v1alpha1/message_pb2.py | 9 | CODE | |
| LOW | …onnect/_proto/redpanda/runtime/v1alpha1/message_pb2.py | 10 | CODE | |
| LOW | …nect/_proto/redpanda/runtime/v1alpha1/processor_pb2.py | 9 | CODE | |
| LOW | …t/_proto/redpanda/runtime/v1alpha1/message_pb2_grpc.py | 3 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py | 3 | CODE | |
| LOW | …_connect/_proto/redpanda/runtime/v1alpha1/agent_pb2.py | 9 | CODE | |
| LOW | …_connect/_proto/redpanda/runtime/v1alpha1/agent_pb2.py | 10 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 3 | CODE | |
| LOW | …_connect/_proto/redpanda/runtime/v1alpha1/input_pb2.py | 9 | CODE | |
| LOW | …connect/_proto/redpanda/runtime/v1alpha1/output_pb2.py | 9 | CODE | |
| LOW | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 3 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | internal/impl/snowflake/streaming/testing/server.go | 123 | "GCS_ACCESS_TOKEN": "fake-token-for-testing", | CODE |
| LOW | …impl/iceberg/integration/connector_integration_test.go | 151 | `{"id":1,"user":{"name":"Alice","email":"alice@example.com","age":30},"address":{"street":"123 Main St","city":"Seatt | CODE |
| LOW⚡ | internal/impl/iceberg/icebergx/partition_key_test.go | 258 | longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nis | CODE |
| LOW⚡ | internal/impl/iceberg/icebergx/partition_key_test.go | 258 | longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nis | CODE |
| LOW⚡ | internal/impl/iceberg/icebergx/partition_key_test.go | 267 | // String should be truncated to 64 bytes: "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellent" | COMMENT |
| LOW⚡ | internal/impl/iceberg/icebergx/partition_key_test.go | 267 | // String should be truncated to 64 bytes: "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellent" | COMMENT |
| LOW | internal/impl/jira/input_jira_test.go | 125 | assert.Equal(t, "user@example.com", cfg.authEmail) | CODE |
| LOW | internal/impl/jira/jiraauth/client_test.go | 54 | c, err := jiraauth.BuildClient(mgr, httpCfg, "user@example.com", "secret-token", 50) | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 32 | sql: `insert into "MYAPP"."CUSTOMERS" ("ID","NAME","EMAIL") values ('1','John Doe','john@example.com')`, | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 35 | "NAME": "John Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 41 | sql: `update "MYAPP"."CUSTOMERS" set "NAME" = 'Jane Doe', "EMAIL" = 'jane@example.com' where "ID" = '1' and "NAME" = | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 41 | sql: `update "MYAPP"."CUSTOMERS" set "NAME" = 'Jane Doe', "EMAIL" = 'jane@example.com' where "ID" = '1' and "NAME" = | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 43 | "NAME": "Jane Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 48 | "NAME": "John Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 53 | sql: `delete from "MYAPP"."CUSTOMERS" where "ID" = '1' and "NAME" = 'John Doe'`, | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 56 | "NAME": "John Doe", | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …al/impl/postgresql/bench/kafka-connector/producer.yaml | 5 | # Usage: | COMMENT |
| LOW | internal/impl/iceberg/demo/docker-compose.yaml | 3 | # Usage: | COMMENT |
| LOW | internal/impl/iceberg/bench/Taskfile.yaml | 96 | # Usage: | COMMENT |
| LOW | internal/impl/iceberg/catalogx/catalog.go | 182 | // Example usage: | COMMENT |
| LOW | …ternal/impl/mysql/bench/mysql-write/rpcn/producer.yaml | 3 | # Usage: | COMMENT |
| LOW | …l/impl/mysql/bench/mysql-write/jdbc-sink/producer.yaml | 5 | # Usage: | COMMENT |
| LOW | internal/impl/salesforce/app/setup.sh | 6 | # Usage: | COMMENT |
| LOW | …impl/aws/s3/bench/write/redpanda-connect/producer.yaml | 3 | # Usage: | COMMENT |
| LOW | …impl/aws/s3/bench/write/redpanda-connect/pipeline.yaml | 3 | # Usage: | COMMENT |
| LOW | …al/impl/aws/s3/bench/write/kafka-connect/producer.yaml | 3 | # Usage: | COMMENT |
| LOW | …nal/impl/aws/s3/bench/read/kafka-connect/producer.yaml | 3 | # Usage: | COMMENT |
| LOW | …ernal/impl/oracledb/bench/docker-compose.debezium.yaml | 5 | # Usage: | COMMENT |
| LOW | internal/singleton/singleton.go | 24 | // Example usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 82 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 102 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 126 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 146 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 167 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 196 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 219 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 240 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 280 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 300 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 320 | except Exception as e: | CODE |
| LOW | public/plugin/python/src/redpanda_connect/_grpc.py | 341 | except Exception as e: | CODE |
| MEDIUM | …nt-search/resources/scripts/format-component-fields.py | 134 | print("Error: Component name required as argument", file=sys.stderr) | CODE |
| MEDIUM | …nt-search/resources/scripts/format-component-fields.py | 154 | print(f"Error: Component '{target_component}' not found in schema", file=sys.stderr) | CODE |
| MEDIUM | …loblang-authoring/resources/scripts/format-bloblang.py | 146 | print("Error: No bloblang items found in schema", file=sys.stderr) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ernal/impl/postgresql/pglogicalstream/pgtype_compat.go | 29 | // NOTE: This function is NOT suitable for arbitrary range types whose | COMMENT |
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 88 | // Step 1: a fetch starts and snapshots the generation. | COMMENT |
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 91 | // Step 2: a concurrent writer evicts (e.g. handleWriteError after a | COMMENT |
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 95 | // Step 3: the in-flight fetch completes and tries to cache its result. | COMMENT |
| LOW | internal/impl/redpanda/migrator/migrator_groups.go | 745 | // NOTE: This method only works when timestamps are monotonically increasing. | COMMENT |
| LOW⚡ | internal/impl/oracledb/checkpoint_cache.go | 185 | // Step 1: Widen the cache_key column. | COMMENT |
| LOW⚡ | internal/impl/oracledb/checkpoint_cache.go | 194 | // Step 2: Rename any legacy 'max_scn' row to the configured cache key. | COMMENT |
| LOW | internal/cli/chroot_linux.go | 30 | // NOTE: This function will only work if the binary is running with | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 103 | CODE | |
| LOW | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 107 | CODE | |
| LOW | …_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py | 111 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py | 49 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 128 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 132 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 136 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 140 | CODE | |
| LOW | …ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py | 144 | CODE | |
| LOW | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 109 | CODE | |
| LOW | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 113 | CODE | |
| LOW | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 117 | CODE | |
| LOW | …ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py | 121 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 88 | // Step 1: a fetch starts and snapshots the generation. | COMMENT |
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 91 | // Step 2: a concurrent writer evicts (e.g. handleWriteError after a | COMMENT |
| LOW⚡ | …l/impl/gcp/enterprise/bigquery/schema_resolver_test.go | 95 | // Step 3: the in-flight fetch completes and tries to cache its result. | COMMENT |
| LOW⚡ | internal/impl/oracledb/checkpoint_cache.go | 185 | // Step 1: Widen the cache_key column. | COMMENT |
| LOW⚡ | internal/impl/oracledb/checkpoint_cache.go | 194 | // Step 2: Rename any legacy 'max_scn' row to the configured cache key. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 147 | # Create the Iceberg namespace used by the connector | COMMENT |
| MEDIUM | …/iceberg/e2e/polaris-aws/terraform/.terraform.lock.hcl | 1 | # This file is maintained automatically by "terraform init". | COMMENT |
| MEDIUM | internal/agent/template/redpanda_agents.yaml | 7 | # Define the tools your agent has access too | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | internal/impl/snowflake/streaming/testing/server.go | 606 | // Return 500 error as requested | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | resources/plugin_uploader/plugin_uploader.py | 55 | def get_archives_version_dir_path(self, version: str) -> str: | CODE |
| LOW | resources/plugin_uploader/plugin_uploader.py | 170 | def create_and_upload_one_archive(artifact: Artifact, plugin_config: PluginConfig, project_root_dir: str, version: str, | CODE |
| LOW | resources/plugin_uploader/plugin_uploader.py | 217 | def create_and_upload_archives( | CODE |
| LOW | resources/plugin_uploader/plugin_uploader.py | 259 | def create_and_upload_manifest_json( | CODE |
| LOW | resources/plugin_uploader/test_plugin_uploader.py | 16 | def create_bucket_and_return_clients(): | CODE |
| LOW | resources/plugin_uploader/test_plugin_uploader.py | 58 | def _run_and_validate_upload_archives( | CODE |
| LOW | resources/plugin_uploader/test_plugin_uploader.py | 84 | def _run_and_validate_upload_manifests(expected_manifest: dict[str, Any]): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | config/rag/README.md | 1 | ## RAG with Redpanda Connect | COMMENT |
| MEDIUM | docs/benchmarking.md | 23 | ├── Taskfile.yaml # Task runner for orchestration | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | internal/impl/iceberg/config.go | 237 | Example(map[string]string{"X-Api-Key": "your-api-key"}). | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | public/plugin/python/src/redpanda_connect/_convert.py | 26 | CODE | |
| LOW | public/plugin/python/src/redpanda_connect/_convert.py | 50 | CODE | |
| LOW | …nt-search/resources/scripts/format-component-fields.py | 21 | CODE | |
| LOW | …loblang-authoring/resources/scripts/format-bloblang.py | 63 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …line-assistant/resources/recipes/stateful-counter.yaml | 61 | # Check if threshold exceeded (circuit breaker) | COMMENT |
| LOW | …ls/pipeline-assistant/resources/recipes/dlq-basic.yaml | 22 | # Check if parsing failed | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | internal/impl/sql/conn_fields.go | 82 | The ` + "`snowflake`" + ` driver supports multiple DSN formats. Please consult https://pkg.go.dev/github.com/snowflakedb | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | public/plugin/python/examples/logging_output.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | public/plugin/python/src/redpanda_connect/__init__.py | 37 | __all__ = [ | CODE |