AI Slop Code Risk Monitor

redpanda-data/connect

SlopCodeMonitor badge for redpanda-data/connect Adjusted legacy signal; badge bands: 25 / 50 / 75 (different from dashboard bands).

Fancy stream processing made operationally mundane

4.1 Low pattern signal View on GitHub

Open-Source Code Quality, Security and Technical Debt Review

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.

4.1
Adjusted Signal
4.1
Raw Pattern Score
100%
Time Factor
2026-10-31
Last Push
8.8K
Stars
Go
Language
434.9K
Lines of Code
1.9K
Files
1.5K
Pattern Hits
2026-10-31
Scan Date
0.01
HC Hit Rate

Risk Review · Payload v1

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.

Cognitive Ownership Risk 15.1/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 1369 finding(s).

Hallucinated Dependency & Supply Chain Risk 0.7/100 · LOW

Are imports declared and package/API names verified? 45 finding(s).

Agent Over-Engineering Ratio 3.6/100 · LOW

Are wrappers, guards, and repeated structures necessary? 124 finding(s).

PR Review Velocity Impact 18.3/100 · LOW

Which changes need focused human review? 1518 finding(s).

What These Metrics Mean

Adjusted Signal
Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score
Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor
A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits
Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate
High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files
Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

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.

Severity Breakdown

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.

CRITICAL 0HIGH 13MEDIUM 89LOW 1416

Directory Score Breakdown

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.

Pattern Findings

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.

Over-Commented Block1298 hits · 1296 pts
SeverityFileLineSnippetContext
LOWcmd/tools/plugins_csv_fmt/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/copies_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/fields.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/fields.go341// Benthos renders these snippets too (ConfigView.TemplateData). They are builtCOMMENT
LOWcmd/tools/docs_gen/platforms.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/platforms.go201// cgoOnlyComponents returns the components, as componentKey values, that theCOMMENT
LOWcmd/tools/docs_gen/schema_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/docs_format_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/description.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/yaml_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/versions_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/versions_test.go41COMMENT
LOWcmd/tools/docs_gen/components_default.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/description_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/roundtrip_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/bloblang_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/spec.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/components_all.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/fields_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/snippet_lint_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/attachment.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/attachment.go21)COMMENT
LOWcmd/tools/docs_gen/attachment_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/yaml.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/platforms_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/summary_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/bloblang.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/allcomponents/allcomponents.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/utils_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/run.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/show.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/cache_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/docker.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/packages.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/cache.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/events.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/utils.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/show_test.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/output.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration/main.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/tools/integration_test_registry/main.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOWcmd/serverless/connect-lambda/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect-ai/sqlite.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect-ai/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect-cloud/sqlite.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect-cloud/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect-community/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/redpanda-connect/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWlicenses/Apache-2.0_header.go.txt1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWlicenses/rcl_header.go.txt1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWconfig/examples/aws_cloudwatch_logs.yaml1# AWS CloudWatch Logs Source Connector (Confluent-compatible)COMMENT
LOWconfig/examples/aws_cloudwatch_logs.yaml21 # start_time: "2024-01-01T00:00:00Z"COMMENT
LOWconfig/examples/aws_cloudwatch_logs.yaml81COMMENT
LOWconfig/examples/stateful_polling.yaml81# generate:COMMENT
LOWresources/docker/profiling/docker-compose.yaml41# jaeger:COMMENT
LOWresources/scripts/third_party_licenses.sh1#!/usr/bin/env bashCOMMENT
LOWinternal/impl/dgraph/cache_ristretto.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/dgraph/cache_ristretto_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/chat_processor_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
1238 more matches not shown…
Decorative Section Separators76 hits · 228 pts
SeverityFileLineSnippetContext
MEDIUMinternal/impl/postgresql/bench/Taskfile.yaml14 # ── PostgreSQL container ──────────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/postgresql/bench/Taskfile.yaml35 # ── Data setup ───────────────────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/postgresql/bench/Taskfile.yaml79 # ── CDC / Snapshot benchmarks ────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/postgresql/bench/Taskfile.yaml129 # ── Kafka → PostgreSQL benchmarks (vs Kafka Connect JDBC Sink) ───────────────COMMENT
MEDIUM…l/postgresql/bench/kafka-connector/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…l/postgresql/bench/kafka-connector/docker-compose.yaml30 # ── PostgreSQL (benchmark sink target) ───────────────────────────────────────COMMENT
MEDIUM…l/postgresql/bench/kafka-connector/docker-compose.yaml46 # ── Kafka Connect + JDBC sink plugin (built from Dockerfile) ─────────────────COMMENT
MEDIUM…l/postgresql/bench/kafka-connector/docker-compose.yaml78 # ── Create bench-events Kafka topic ──────────────────────────────────────────COMMENT
MEDIUM…l/postgresql/bench/kafka-connector/docker-compose.yaml96 # ── Create bench_events table in PostgreSQL ───────────────────────────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml30 # ── MinIO (S3-compatible object storage) ─────────────────────────────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml48 # ── Create the 'warehouse' S3 bucket ─────────────────────────────────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml63 # ── Iceberg REST catalog ──────────────────────────────────────────────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml86 # ── Kafka Connect + Iceberg sink plugin (built from Dockerfile) ───────────────COMMENT
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml122 # ── Create bench-events topic and the Iceberg 'benchmark' namespace ───────────COMMENT
MEDIUMinternal/impl/mysql/bench/Taskfile.yaml11 # ── MySQL container ───────────────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/mysql/bench/Taskfile.yaml36 # ── Data setup ───────────────────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/mysql/bench/Taskfile.yaml63 # ── Benchmarks ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml30 # ── MySQL (benchmark sink target) ────────────────────────────────────────────COMMENT
MEDIUM…/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml45 # ── Create bench-events Kafka topic ──────────────────────────────────────────COMMENT
MEDIUM…/impl/mysql/bench/mysql-write/rpcn/docker-compose.yaml63 # ── Create bench_events table in MySQL ───────────────────────────────────────COMMENT
MEDIUM…/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml30 # ── MySQL (benchmark sink target) ────────────────────────────────────────────COMMENT
MEDIUM…/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml45 # ── Kafka Connect + JDBC sink plugin (built from Dockerfile) ─────────────────COMMENT
MEDIUM…/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml77 # ── Create bench-events Kafka topic ──────────────────────────────────────────COMMENT
MEDIUM…/mysql/bench/mysql-write/jdbc-sink/docker-compose.yaml95 # ── Create bench_events table in MySQL ───────────────────────────────────────COMMENT
MEDIUM…l/impl/mysql/bench/mysql-read/rpcn/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…l/impl/mysql/bench/mysql-read/rpcn/docker-compose.yaml30 # ── MySQL (binlog enabled — mysql_cdc source) ─────────────────────────────────COMMENT
MEDIUM…pl/mysql/bench/mysql-read/debezium/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…pl/mysql/bench/mysql-read/debezium/docker-compose.yaml30 # ── MySQL (binlog enabled — Debezium source) ─────────────────────────────────COMMENT
MEDIUM…pl/mysql/bench/mysql-read/debezium/docker-compose.yaml52 # ── Kafka Connect + Debezium MySQL source plugin ──────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml10 # ── Pipeline parameters ───────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml16 # ── Matrix sweep lists ────────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml30 # ── Infrastructure ────────────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml45 # ── Pipeline lifecycle ────────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml92 # ── Data management ───────────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml112 # ── Observation ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml129 # ── Single parameterised run ──────────────────────────────────────────────────COMMENT
MEDIUM…impl/aws/s3/bench/write/redpanda-connect/Taskfile.yaml221 # ── Logs ──────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…l/aws/s3/bench/write/kafka-connect/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…l/aws/s3/bench/write/kafka-connect/docker-compose.yaml30 # ── LocalStack (S3 sink target) ───────────────────────────────────────────────COMMENT
MEDIUM…l/aws/s3/bench/write/kafka-connect/docker-compose.yaml46 # ── Kafka Connect + S3 Sink plugin (built from Dockerfile) ───────────────────COMMENT
MEDIUM…l/aws/s3/bench/write/kafka-connect/docker-compose.yaml86 # ── Create bench-events Kafka topic ──────────────────────────────────────────COMMENT
MEDIUM…l/aws/s3/bench/write/kafka-connect/docker-compose.yaml104 # ── Create bench-events S3 bucket in LocalStack ───────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml12 # ── Connector parameters (used by connector:create and bench:run) ─────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml23 # ── Matrix sweep lists (space-separated values to try for each parameter) ─────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml31 # ── Infrastructure ────────────────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml45 # ── Connector management ──────────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml118 # ── Data loading ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml138 # ── Observation ───────────────────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml241 # ── Single parameterised run ──────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml350 # ── Matrix sweep ──────────────────────────────────────────────────────────────COMMENT
MEDIUM…al/impl/aws/s3/bench/write/kafka-connect/Taskfile.yaml515 # ── Logs ──────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml2 # ── Kafka (KRaft, no ZooKeeper) ──────────────────────────────────────────────COMMENT
MEDIUM…pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml30 # ── LocalStack (S3 source) ────────────────────────────────────────────────────COMMENT
MEDIUM…pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml46 # ── Kafka Connect + S3 plugin ─────────────────────────────────────────────────COMMENT
MEDIUM…pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml84 # ── Create bench-events Kafka topic ──────────────────────────────────────────COMMENT
MEDIUM…pl/aws/s3/bench/read/kafka-connect/docker-compose.yaml102 # ── Create bench-events S3 bucket in LocalStack ───────────────────────────────COMMENT
MEDIUM…nal/impl/aws/s3/bench/read/kafka-connect/Taskfile.yaml25 # ── Infrastructure ────────────────────────────────────────────────────────────COMMENT
16 more matches not shown…
Cross-File Repetition11 hits · 55 pts
SeverityFileLineSnippetContext
HIGH…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py0client and server classes corresponding to protobuf-defined services.STRING
HIGH…t/_proto/redpanda/runtime/v1alpha1/message_pb2_grpc.py0client and server classes corresponding to protobuf-defined services.STRING
HIGH…ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py0client and server classes corresponding to protobuf-defined services.STRING
HIGH…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py0client and server classes corresponding to protobuf-defined services.STRING
HIGH…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py0client and server classes corresponding to protobuf-defined services.STRING
HIGH…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py0init 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.py0init 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.py0init 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.py0close 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.py0close 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.py0close the component, blocks until either the underlying resources are cleaned up or the rpc deadline is reached.STRING
Unused Imports27 hits · 27 pts
SeverityFileLineSnippetContext
LOWpublic/plugin/python/src/redpanda_connect/__init__.py19CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py19CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py19CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py20CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py30CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py30CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py30CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py30CODE
LOW…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py3CODE
LOW…onnect/_proto/redpanda/runtime/v1alpha1/message_pb2.py9CODE
LOW…onnect/_proto/redpanda/runtime/v1alpha1/message_pb2.py10CODE
LOW…nect/_proto/redpanda/runtime/v1alpha1/processor_pb2.py9CODE
LOW…t/_proto/redpanda/runtime/v1alpha1/message_pb2_grpc.py3CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py3CODE
LOW…_connect/_proto/redpanda/runtime/v1alpha1/agent_pb2.py9CODE
LOW…_connect/_proto/redpanda/runtime/v1alpha1/agent_pb2.py10CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py3CODE
LOW…_connect/_proto/redpanda/runtime/v1alpha1/input_pb2.py9CODE
LOW…connect/_proto/redpanda/runtime/v1alpha1/output_pb2.py9CODE
LOW…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py3CODE
Structural Annotation Overuse12 hits · 25 pts
SeverityFileLineSnippetContext
LOW…ernal/impl/postgresql/pglogicalstream/pgtype_compat.go29// NOTE: This function is NOT suitable for arbitrary range types whoseCOMMENT
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go88 // Step 1: a fetch starts and snapshots the generation.COMMENT
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go91 // Step 2: a concurrent writer evicts (e.g. handleWriteError after aCOMMENT
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go95 // Step 3: the in-flight fetch completes and tries to cache its result.COMMENT
LOWinternal/impl/redpanda/migrator/migrator_groups.go745// NOTE: This method only works when timestamps are monotonically increasing.COMMENT
LOW⚡internal/impl/oracledb/checkpoint_cache.go185 // Step 1: Widen the cache_key column.COMMENT
LOW⚡internal/impl/oracledb/checkpoint_cache.go194 // Step 2: Rename any legacy 'max_scn' row to the configured cache key.COMMENT
LOWinternal/cli/chroot_linux.go30// NOTE: This function will only work if the binary is running withCOMMENT
LOW⚡internal/replication/ticket/example_test.go31 // Step 1: flush and draw a ticket in the same critical section.COMMENT
LOW⚡internal/replication/ticket/example_test.go40 // Step 2: release the ticket when we are done, also on errorCOMMENT
LOW⚡internal/replication/ticket/example_test.go44 // Step 3: wait for our turn.COMMENT
LOW⚡internal/replication/ticket/example_test.go49 // Step 4: the slow work, for example track and send. TheCOMMENT
Fake / Example Data17 hits · 24 pts
SeverityFileLineSnippetContext
LOW…impl/snowflake/output_snowflake_streaming_pipe_test.go1169private_key: dummy-keyCODE
LOWinternal/impl/snowflake/streaming/testing/server.go123 "GCS_ACCESS_TOKEN": "fake-token-for-testing",CODE
LOW…impl/iceberg/integration/connector_integration_test.go152 `{"id":1,"user":{"name":"Alice","email":"alice@example.com","age":30},"address":{"street":"123 Main St","city":"SeattCODE
LOW⚡internal/impl/iceberg/icebergx/partition_key_test.go258 longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nisCODE
LOW⚡internal/impl/iceberg/icebergx/partition_key_test.go258 longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nisCODE
LOW⚡internal/impl/iceberg/icebergx/partition_key_test.go267 // 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.go267 // String should be truncated to 64 bytes: "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellent"COMMENT
LOWinternal/impl/jira/input_jira_test.go119 assert.Equal(t, "user@example.com", cfg.authEmail)CODE
LOWinternal/impl/jira/jiraauth/client_test.go48 c, err := jiraauth.BuildClient(mgr, httpCfg, "user@example.com", "secret-token", 50)CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go33 sql: `insert into "MYAPP"."CUSTOMERS" ("ID","NAME","EMAIL") values ('1','John Doe','john@example.com')`,CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go36 "NAME": "John Doe",CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go42 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.go42 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.go44 "NAME": "Jane Doe",CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go49 "NAME": "John Doe",CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go54 sql: `delete from "MYAPP"."CUSTOMERS" where "ID" = '1' and "NAME" = 'John Doe'`,CODE
LOW⚡internal/impl/oracledb/logminer/sqlredo/parser_test.go57 "NAME": "John Doe",CODE
Verbosity Indicators9 hits · 20 pts
SeverityFileLineSnippetContext
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go88 // Step 1: a fetch starts and snapshots the generation.COMMENT
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go91 // Step 2: a concurrent writer evicts (e.g. handleWriteError after aCOMMENT
LOW⚡…l/impl/gcp/enterprise/bigquery/schema_resolver_test.go95 // Step 3: the in-flight fetch completes and tries to cache its result.COMMENT
LOW⚡internal/impl/oracledb/checkpoint_cache.go185 // Step 1: Widen the cache_key column.COMMENT
LOW⚡internal/impl/oracledb/checkpoint_cache.go194 // Step 2: Rename any legacy 'max_scn' row to the configured cache key.COMMENT
LOW⚡internal/replication/ticket/example_test.go31 // Step 1: flush and draw a ticket in the same critical section.COMMENT
LOW⚡internal/replication/ticket/example_test.go40 // Step 2: release the ticket when we are done, also on errorCOMMENT
LOW⚡internal/replication/ticket/example_test.go44 // Step 3: wait for our turn.COMMENT
LOW⚡internal/replication/ticket/example_test.go49 // Step 4: the slow work, for example track and send. TheCOMMENT
Example Usage Blocks13 hits · 20 pts
SeverityFileLineSnippetContext
LOW…al/impl/postgresql/bench/kafka-connector/producer.yaml5# Usage:COMMENT
LOWinternal/impl/iceberg/demo/docker-compose.yaml3# Usage:COMMENT
LOWinternal/impl/iceberg/bench/Taskfile.yaml102 # Usage:COMMENT
LOWinternal/impl/iceberg/catalogx/catalog.go182// Example usage:COMMENT
LOW…ternal/impl/mysql/bench/mysql-write/rpcn/producer.yaml3# Usage:COMMENT
LOW…l/impl/mysql/bench/mysql-write/jdbc-sink/producer.yaml5# Usage:COMMENT
LOWinternal/impl/salesforce/app/setup.sh6# Usage:COMMENT
LOW…impl/aws/s3/bench/write/redpanda-connect/producer.yaml3# Usage:COMMENT
LOW…impl/aws/s3/bench/write/redpanda-connect/pipeline.yaml3# Usage:COMMENT
LOW…al/impl/aws/s3/bench/write/kafka-connect/producer.yaml3# Usage:COMMENT
LOW…nal/impl/aws/s3/bench/read/kafka-connect/producer.yaml3# Usage:COMMENT
LOW…ernal/impl/oracledb/bench/docker-compose.debezium.yaml5# Usage:COMMENT
LOWinternal/singleton/singleton.go24// Example usage:COMMENT
Excessive Try-Catch Wrapping15 hits · 18 pts
SeverityFileLineSnippetContext
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py82 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py102 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py126 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py146 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py167 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py196 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py219 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py240 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py280 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py300 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py320 except Exception as e:CODE
LOWpublic/plugin/python/src/redpanda_connect/_grpc.py341 except Exception as e:CODE
MEDIUM…nt-search/resources/scripts/format-component-fields.py134 print("Error: Component name required as argument", file=sys.stderr)CODE
MEDIUM…nt-search/resources/scripts/format-component-fields.py154 print(f"Error: Component '{target_component}' not found in schema", file=sys.stderr)CODE
MEDIUM…loblang-authoring/resources/scripts/format-bloblang.py146 print("Error: No bloblang items found in schema", file=sys.stderr)CODE
AI Structural Patterns13 hits · 13 pts
SeverityFileLineSnippetContext
LOW…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py103CODE
LOW…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py107CODE
LOW…_proto/redpanda/runtime/v1alpha1/processor_pb2_grpc.py111CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/agent_pb2_grpc.py49CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py128CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py132CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py136CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py140CODE
LOW…ect/_proto/redpanda/runtime/v1alpha1/input_pb2_grpc.py144CODE
LOW…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py109CODE
LOW…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py113CODE
LOW…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py117CODE
LOW…ct/_proto/redpanda/runtime/v1alpha1/output_pb2_grpc.py121CODE
Self-Referential Comments4 hits · 12 pts
SeverityFileLineSnippetContext
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml147 # Create the Iceberg namespace used by the connectorCOMMENT
MEDIUM…l/iceberg/e2e/databricks/terraform/.terraform.lock.hcl1# This file is maintained automatically by "terraform init".COMMENT
MEDIUM…/iceberg/e2e/polaris-aws/terraform/.terraform.lock.hcl1# This file is maintained automatically by "terraform init".COMMENT
MEDIUMinternal/agent/template/redpanda_agents.yaml7 # Define the tools your agent has access tooCOMMENT
Modern AI Meta-Vocabulary3 hits · 8 pts
SeverityFileLineSnippetContext
MEDIUMconfig/rag/README.md1## RAG with Redpanda ConnectCOMMENT
MEDIUMdocs/benchmarking.md40├── Taskfile.yaml # Task runner for orchestrationCODE
MEDIUMbenchmarking/aws/terraform/persistent/gha.tf63# with no customer data — the real guardrails are the pinned OIDC trustCOMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGHinternal/impl/snowflake/streaming/testing/server.go606 // Return 500 error as requestedCOMMENT
Hyper-Verbose Identifiers7 hits · 7 pts
SeverityFileLineSnippetContext
LOWresources/plugin_uploader/plugin_uploader.py55 def get_archives_version_dir_path(self, version: str) -> str:CODE
LOWresources/plugin_uploader/plugin_uploader.py170def create_and_upload_one_archive(artifact: Artifact, plugin_config: PluginConfig, project_root_dir: str, version: str,CODE
LOWresources/plugin_uploader/plugin_uploader.py217def create_and_upload_archives(CODE
LOWresources/plugin_uploader/plugin_uploader.py259def create_and_upload_manifest_json(CODE
LOWresources/plugin_uploader/test_plugin_uploader.py16def create_bucket_and_return_clients():CODE
LOWresources/plugin_uploader/test_plugin_uploader.py58 def _run_and_validate_upload_archives(CODE
LOWresources/plugin_uploader/test_plugin_uploader.py84 def _run_and_validate_upload_manifests(expected_manifest: dict[str, Any]):CODE
AI Slop Vocabulary2 hits · 6 pts
SeverityFileLineSnippetContext
MEDIUMinternal/impl/oracledb/integration_test.go527 // since seamless recovery isn't what this test expects (see doc comment above).COMMENT
MEDIUM.github/workflows/test.yml189 # The benchmarking harness lives in standalone Go modulesCOMMENT
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHinternal/impl/iceberg/config.go328 Example(map[string]string{"X-Api-Key": "your-api-key"}).CODE
Deep Nesting4 hits · 4 pts
SeverityFileLineSnippetContext
LOWpublic/plugin/python/src/redpanda_connect/_convert.py26CODE
LOWpublic/plugin/python/src/redpanda_connect/_convert.py50CODE
LOW…nt-search/resources/scripts/format-component-fields.py21CODE
LOW…loblang-authoring/resources/scripts/format-bloblang.py63CODE
Redundant / Tautological Comments2 hits · 3 pts
SeverityFileLineSnippetContext
LOW…line-assistant/resources/recipes/stateful-counter.yaml61 # Check if threshold exceeded (circuit breaker)COMMENT
LOW…ls/pipeline-assistant/resources/recipes/dlq-basic.yaml22 # Check if parsing failedCOMMENT
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUMinternal/impl/sql/conn_fields.go83The ` + "`snowflake`" + ` driver supports multiple DSN formats. Please consult https://pkg.go.dev/github.com/snowflakedbCODE
Modern Structural Boilerplate2 hits · 2 pts
SeverityFileLineSnippetContext
LOWpublic/plugin/python/examples/logging_output.py22logger = logging.getLogger(__name__)CODE
LOWpublic/plugin/python/src/redpanda_connect/__init__.py37__all__ = [CODE