Fancy stream processing made operationally mundane
This report summarizes scanner evidence for redpanda-data/connect, a Go project with 8,793 GitHub stars. SynthScan examined 434,871 lines of code across 1908 source files, recording 1518 pattern matches distributed across 20 syntactic categories. The legacy adjusted pattern signal is 4.1 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.
Can maintainers explain intent, assumptions, and trade-offs? 1369 finding(s).
Are imports declared and package/API names verified? 45 finding(s).
Are wrappers, guards, and repeated structures necessary? 124 finding(s).
Which changes need focused human review? 1518 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 1518 distinct pattern matches across 20 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| 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/copies_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/fields.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/fields.go | 341 | // Benthos renders these snippets too (ConfigView.TemplateData). They are built | COMMENT |
| LOW | cmd/tools/docs_gen/platforms.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/platforms.go | 201 | // cgoOnlyComponents returns the components, as componentKey values, that the | COMMENT |
| LOW | cmd/tools/docs_gen/schema_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/docs_format_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/description.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/yaml_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/versions_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/versions_test.go | 41 | COMMENT | |
| LOW | cmd/tools/docs_gen/components_default.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/description_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/roundtrip_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/bloblang_test.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/spec.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/components_all.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/fields_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/snippet_lint_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/attachment.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/attachment.go | 21 | ) | COMMENT |
| LOW | cmd/tools/docs_gen/attachment_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/yaml.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/platforms_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/main.go | 1 | // Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/summary_test.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/bloblang.go | 1 | // Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | cmd/tools/docs_gen/allcomponents/allcomponents.go | 1 | // Copyright 2026 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 | 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 |
| 1238 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 | 79 | # ── CDC / Snapshot benchmarks ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | internal/impl/postgresql/bench/Taskfile.yaml | 129 | # ── 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 |
| 16 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 | …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 |
| LOW⚡ | internal/replication/ticket/example_test.go | 31 | // Step 1: flush and draw a ticket in the same critical section. | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 40 | // Step 2: release the ticket when we are done, also on error | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 44 | // Step 3: wait for our turn. | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 49 | // Step 4: the slow work, for example track and send. The | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …impl/snowflake/output_snowflake_streaming_pipe_test.go | 1169 | private_key: dummy-key | CODE |
| 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 | 152 | `{"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 | 119 | assert.Equal(t, "user@example.com", cfg.authEmail) | CODE |
| LOW | internal/impl/jira/jiraauth/client_test.go | 48 | c, err := jiraauth.BuildClient(mgr, httpCfg, "user@example.com", "secret-token", 50) | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 33 | 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 | 36 | "NAME": "John Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 42 | 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 | 42 | 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 | 44 | "NAME": "Jane Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 49 | "NAME": "John Doe", | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 54 | sql: `delete from "MYAPP"."CUSTOMERS" where "ID" = '1' and "NAME" = 'John Doe'`, | CODE |
| LOW⚡ | internal/impl/oracledb/logminer/sqlredo/parser_test.go | 57 | "NAME": "John Doe", | 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 |
| LOW⚡ | internal/replication/ticket/example_test.go | 31 | // Step 1: flush and draw a ticket in the same critical section. | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 40 | // Step 2: release the ticket when we are done, also on error | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 44 | // Step 3: wait for our turn. | COMMENT |
| LOW⚡ | internal/replication/ticket/example_test.go | 49 | // Step 4: the slow work, for example track and send. The | COMMENT |
| 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 | 102 | # 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 | …_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 |
|---|---|---|---|---|
| MEDIUM | …impl/iceberg/bench/kafka-connector/docker-compose.yaml | 147 | # Create the Iceberg namespace used by the connector | COMMENT |
| MEDIUM | …l/iceberg/e2e/databricks/terraform/.terraform.lock.hcl | 1 | # This file is maintained automatically by "terraform init". | 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 |
|---|---|---|---|---|
| MEDIUM | config/rag/README.md | 1 | ## RAG with Redpanda Connect | COMMENT |
| MEDIUM | docs/benchmarking.md | 40 | ├── Taskfile.yaml # Task runner for orchestration | CODE |
| MEDIUM | benchmarking/aws/terraform/persistent/gha.tf | 63 | # with no customer data — the real guardrails are the pinned OIDC trust | 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 | internal/impl/oracledb/integration_test.go | 527 | // since seamless recovery isn't what this test expects (see doc comment above). | COMMENT |
| MEDIUM | .github/workflows/test.yml | 189 | # The benchmarking harness lives in standalone Go modules | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | internal/impl/iceberg/config.go | 328 | 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 | 83 | 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 |