Repository Analysis

redpanda-data/connect

Fancy stream processing made operationally mundane

4.2 Likely human-written View on GitHub

Analysis Overview

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).

4.2
Adjusted Score
4.2
Raw Score
100%
Time Factor
2026-08-07
Last Push
8.7K
Stars
Go
Language
317.3K
Lines of Code
1.5K
Files
1.1K
Pattern Hits
2026-08-09
Scan Date
0.01
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

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.

No multi-scan history yet — run the scanner again to build trend data.

Severity Breakdown

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.

CRITICAL 0HIGH 13MEDIUM 75LOW 1012

Directory Score Breakdown

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.

Pattern Findings

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.

Over-Commented Block903 hits · 903 pts
SeverityFileLineSnippetContext
LOWcmd/tools/plugins_csv_fmt/main.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/schema_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/bloblang_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWcmd/tools/docs_gen/main.go1// Copyright 2024 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.yaml81 # Alternative: Output to stdout for testingCOMMENT
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
LOWinternal/impl/cohere/embeddings_processor.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/rerank_processor_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/chat_processor.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/json_schema_provider.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/base_processor.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/cohere/rerank_processor.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/postgresql/integration_test.go361 // A real process crash drops the connection, so postgres releases theCOMMENT
LOW…al/impl/postgresql/bench/kafka-connector/producer.yaml1# Produces COUNT synthetic events to the bench-events Kafka topic.COMMENT
LOW…impl/postgresql/pglogicalstream/replication_message.go481// UpdateMessage is a update message.COMMENT
LOWinternal/impl/postgresql/pglogicalstream/pglogrepl.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOW…ernal/impl/postgresql/pglogicalstream/pgtype_compat.go1// Copyright 2026 Redpanda Data, Inc.COMMENT
LOW…ernal/impl/postgresql/pglogicalstream/pgtype_compat.go21//COMMENT
LOW…l/postgresql/pglogicalstream/sanitize/sanitize_test.go1// Copyright (c) 2013-2021 Jack ChristensenCOMMENT
LOW…l/impl/postgresql/pglogicalstream/sanitize/sanitize.go1// Copyright (c) 2013-2021 Jack ChristensenCOMMENT
LOWinternal/impl/postgresql/aws/aws.go1// Copyright 2025 Redpanda Data, Inc.COMMENT
LOWinternal/impl/twitter/init.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/bcrypt_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/jwt_parse_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/jwt_sign.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/argon2_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/argon2.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/argon2.go41 memory uint32COMMENT
LOWinternal/impl/crypto/jwt_sign_test.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/bcrypt.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
LOWinternal/impl/crypto/jwt_parse.go1// Copyright 2024 Redpanda Data, Inc.COMMENT
843 more matches not shown…
Decorative Section Separators66 hits · 198 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.yaml67 # ── CDC / Snapshot benchmarks ────────────────────────────────────────────────COMMENT
MEDIUMinternal/impl/postgresql/bench/Taskfile.yaml117 # ── 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
6 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
Fake / Example Data16 hits · 24 pts
SeverityFileLineSnippetContext
LOWinternal/impl/snowflake/streaming/testing/server.go123 "GCS_ACCESS_TOKEN": "fake-token-for-testing",CODE
LOW…impl/iceberg/integration/connector_integration_test.go151 `{"id":1,"user":{"name":"Alice","email":"alice@example.com","age":30},"address":{"street":"123 Main St","city":"SeattCODE
LOWinternal/impl/iceberg/icebergx/partition_key_test.go258 longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nisCODE
LOWinternal/impl/iceberg/icebergx/partition_key_test.go258 longString := "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque ipsum magna, pellentesque quis nisCODE
LOWinternal/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/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.go125 assert.Equal(t, "user@example.com", cfg.authEmail)CODE
LOWinternal/impl/jira/jiraauth/client_test.go54 c, err := jiraauth.BuildClient(mgr, httpCfg, "user@example.com", "secret-token", 50)CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go32 sql: `insert into "MYAPP"."CUSTOMERS" ("ID","NAME","EMAIL") values ('1','John Doe','john@example.com')`,CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go35 "NAME": "John Doe",CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go41 sql: `update "MYAPP"."CUSTOMERS" set "NAME" = 'Jane Doe', "EMAIL" = 'jane@example.com' where "ID" = '1' and "NAME" =CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go41 sql: `update "MYAPP"."CUSTOMERS" set "NAME" = 'Jane Doe', "EMAIL" = 'jane@example.com' where "ID" = '1' and "NAME" =CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go43 "NAME": "Jane Doe",CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go48 "NAME": "John Doe",CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go53 sql: `delete from "MYAPP"."CUSTOMERS" where "ID" = '1' and "NAME" = 'John Doe'`,CODE
LOWinternal/impl/oracledb/logminer/sqlredo/parser_test.go56 "NAME": "John Doe",CODE
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.yaml96 # 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
Structural Annotation Overuse8 hits · 16 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
LOWinternal/impl/oracledb/checkpoint_cache.go185 // Step 1: Widen the cache_key column.COMMENT
LOWinternal/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
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
Verbosity Indicators5 hits · 11 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
LOWinternal/impl/oracledb/checkpoint_cache.go185 // Step 1: Widen the cache_key column.COMMENT
LOWinternal/impl/oracledb/checkpoint_cache.go194 // Step 2: Rename any legacy 'max_scn' row to the configured cache key.COMMENT
Self-Referential Comments3 hits · 9 pts
SeverityFileLineSnippetContext
MEDIUM…impl/iceberg/bench/kafka-connector/docker-compose.yaml147 # Create the Iceberg namespace used by the connectorCOMMENT
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
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
Modern AI Meta-Vocabulary2 hits · 5 pts
SeverityFileLineSnippetContext
MEDIUMconfig/rag/README.md1## RAG with Redpanda ConnectCOMMENT
MEDIUMdocs/benchmarking.md23├── Taskfile.yaml # Task runner for orchestrationCODE
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHinternal/impl/iceberg/config.go237 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.go82The ` + "`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