Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
This report presents the forensic synthetic code analysis of redpanda-data/redpanda, a C++ project with 12,335 GitHub stars. SynthScan v2.0 examined 696,279 lines of code across 3695 source files, recording 4397 pattern matches distributed across 22 syntactic categories. The overall adjusted score of 7.4 places this repository in the Low AI signal 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).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 4397 distinct pattern matches across 22 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/redpanda-gdb.py | 136 | def read_kafka_optional_string(self): | CODE |
| LOW | tools/redpanda-gdb.py | 509 | def absl_insert_version_after_absl(cpp_name): | CODE |
| LOW | tools/redpanda-gdb.py | 626 | def has_enable_lw_shared_from_this(type): | CODE |
| LOW | tools/redpanda-gdb.py | 736 | def external_memory_footprint(self): | CODE |
| LOW | tools/redpanda-gdb.py | 1119 | def find_cloud_storage_clients(shard=None): | CODE |
| LOW | tools/redpanda-gdb.py | 1264 | def batch_cache_index_size_bytes(self): | CODE |
| LOW | tools/redpanda-gdb.py | 1312 | def get_template_arg_with_prefix(gdb_type, prefix): | CODE |
| LOW | tools/redpanda-gdb.py | 1484 | def print_readers_cache_memory(self): | CODE |
| LOW | tools/redpanda-gdb.py | 1615 | def print_readers_cache_memory(self): | CODE |
| LOW | tools/redpanda-gdb.py | 3375 | def get_seastar_memory_start_and_size(): | CODE |
| LOW | tools/redpanda-gdb.py | 3402 | def is_seastar_allocator_used(): | CODE |
| LOW | tools/dev_cluster.py | 154 | def cpuset_hardware_core_count() -> int: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 505 | def wait_for_port_forward_ready(process: subprocess.Popen, timeout: int = 30) -> bool: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 645 | def _summarize_cfr_invocation(cfr_invokers: list[CFRInvoker]) -> None: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 802 | def _confirm_with_user_or_cancel(prompt: str) -> None: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 809 | def handle_kubernetes_command( | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 847 | def perform_liveness_check_and_get_cfr_params( | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 882 | def _broker_responses_to_consensus( | CODE |
| LOW | tools/antithesis/single_binary_test_package.py | 204 | def resolve_and_query_targets( | CODE |
| LOW | tools/offline_log_viewer/kvstore.py | 141 | def decode_raft_metadata_type(k): | CODE |
| LOW | tools/offline_log_viewer/kvstore.py | 225 | def decode_offset_translator_key(k): | CODE |
| LOW | tools/offline_log_viewer/kvstore.py | 275 | def decode_shard_placement_key(k): | CODE |
| LOW | tools/offline_log_viewer/kvstore.py | 335 | def decode_offset_translator_value(type, v): | CODE |
| LOW | tools/offline_log_viewer/viewer.py | 100 | def print_controller_snapshot(self): | CODE |
| LOW | tools/offline_log_viewer/viewer.py | 154 | def print_consumer_offsets_summary(self): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 14 | def read_remote_topic_properties_serde(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 42 | def read_topic_properties_serde(rdr: Reader, version): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 213 | def read_topic_configuration_assignment_serde(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 243 | def read_property_update_serde(rdr: Reader, type_reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 252 | def read_incremental_topic_update_serde(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 417 | def read_create_partitions_serde(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 443 | def decode_topic_command_serde(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 655 | def decode_user_command_serde(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 742 | def decode_serialized_pattern_type(v): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 748 | def read_acl_binding_filter_serde(k_rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 840 | def decode_config_command_serde(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 875 | def decode_config_command_adl(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 918 | def decode_feature_command_serde(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 948 | def decode_feature_command_adl(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 949 | def decode_feature_update_action(r): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 967 | def decode_node_management_command(k_rdr: Reader, rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 993 | def decode_user_and_credential(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1010 | def decode_bootstrap_cluster_cmd_data(rdr: Reader, version): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1022 | def decode_cluster_bootstrap_command(k_rdr, rdr): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1115 | def read_feature_state_snapshot(rdr: Reader, version: int): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1132 | def read_features_table_snapshot(rdr: Reader, version: int): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1160 | def read_topic_metadata_fields(rdr: Reader, v: int): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1170 | def read_disabled_partitions_set(rdr: Reader, v: int): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1364 | def read_ntp_with_majority_loss(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1404 | def read_cluster_metadata_manifest(rdr: Reader, version: int): | CODE |
| LOW | tools/offline_log_viewer/controller.py | 1417 | def read_cluster_recovery_state(rdr: Reader, version: int): | CODE |
| LOW | tools/offline_log_viewer/model.py | 38 | def read_incremental_properties_update(reader): | CODE |
| LOW | tools/offline_log_viewer/model.py | 86 | def read_unresolved_address_adl(r: Reader): | CODE |
| LOW | tools/offline_log_viewer/model.py | 112 | def read_broker_properties_adl(r: Reader): | CODE |
| LOW⚡ | tools/offline_log_viewer/model.py | 154 | def read_configuration_update(rdr): | CODE |
| LOW⚡ | tools/offline_log_viewer/model.py | 161 | def decode_configuration_update(rdr: Reader, version: int): | CODE |
| LOW⚡ | tools/offline_log_viewer/model.py | 170 | def read_configuration_update_serde(rdr: Reader): | CODE |
| LOW | tools/offline_log_viewer/model.py | 298 | def decode_acl_principal_type(p): | CODE |
| LOW | tools/offline_log_viewer/model.py | 377 | def read_partition_assignment(rdr): | CODE |
| LOW | tools/offline_log_viewer/reader.py | 113 | def read_kafka_optional_string(self): | CODE |
| 1831 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/clang-tool-parallel.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/duckdb.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/redpanda-gdb.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/dev_cluster.py | 1 | #!/usr/bin/python3 | COMMENT |
| LOW | tools/dev_cluster.py | 121 | cluster_size: int | COMMENT |
| LOW | tools/check-copyright-year.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/spark-sql.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …command_generator/leader_transfer_command_generator.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | tools/antithesis/ducktape_test_package.py | 1 | #!/usr/bin/python3 | COMMENT |
| LOW | tools/antithesis/ducktape_test_package.py | 21 | # This script: | COMMENT |
| LOW | tools/antithesis/single_binary_test_package.py | 1 | #!/usr/bin/python3 | COMMENT |
| LOW | tools/antithesis/single_binary_test_package.py | 21 | # the workload/config images to the registry (unless --skip-registry-upload) | COMMENT |
| LOW | tools/antithesis/at_common.py | 1 | # ================================================================== | COMMENT |
| LOW | tools/antithesis/ducktape_deps/ducktape_entrypoint.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …/antithesis/ducktape_deps/ducktape_singleton_driver.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/bazel-tools/support/bazel-tool-trampoline.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/rp_storage_tool/src/ntp_mask.rs | 81 | // if let Some(grps) = NTP_MASK_EXPR.captures(input) { | COMMENT |
| LOW | tools/rp_storage_tool/src/bucket_reader.rs | 161 | // // Ambiguous case: two objects at same base offset uploaded in the same term can be: | COMMENT |
| LOW | tools/rp_storage_tool/src/bucket_reader.rs | 1421 | ) -> impl Stream<Item = SegmentStream> + '_ { | COMMENT |
| LOW | tools/rp_storage_tool/src/remote_types.rs | 281 | COMMENT | |
| LOW | tools/rp_storage_tool/src/remote_types.rs | 301 | // gauge_col_t _delta_offset_end{}; | COMMENT |
| LOW | tools/rp_storage_tool/src/remote_types.rs | 441 | #[serde(skip_serializing_if = "offset_has_default_value")] | COMMENT |
| LOW | tools/tests/run_cov_test.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ols/schema_registry_tools/schemas_command_generator.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | …ols/schema_registry_tools/schemas_command_generator.py | 21 | # 4. Run the generated script above | COMMENT |
| LOW | tools/build-perf/build-timer.py | 221 | # "--strip=never --copt -gline-tables-only", | COMMENT |
| LOW | …cloud_storage_name_mapper/cloud_storage_name_mapper.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | licenses/boilerplate.go.txt | 1 | // Copyright 2022 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 721 | COMMENT | |
| LOW | …go/kgo-verifier/pkg/worker/repeater/repeater_worker.go | 1 | package loop | COMMENT |
| LOW | tests/antithesis/fixture_test_targets.yml | 1 | # Bazel target patterns packaged and submitted to Antithesis by the | COMMENT |
| LOW | tests/rptest/test_suite_fuzz.yml | 1 | # Copyright 2025 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_pandaproxy.yml | 1 | # Copyright 2020 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_cloud_self_test.yml | 1 | # Copyright 2023 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/__init__.py | 1 | # Copyright 2020 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_infinite_retention.yml | 1 | # Copyright 2023 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_nightly.yml | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_iceberg_cloud.yml | 1 | # Copyright 2025 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_chaos.yml | 1 | # Copyright 2024 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_all.yml | 1 | # Copyright 2020 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/test_suite_perf.yml | 1 | # Copyright 2022 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/clients/__init__.py | 1 | # Copyright 2020 Redpanda Data, Inc. | COMMENT |
| LOW | …s/rptest/infinite_retention/infinite_retention_test.py | 61 | # How much messages should we wait on start | COMMENT |
| LOW | tests/rptest/infinite_retention/checks.py | 1 | # Copyright 2023 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/leader_election_test.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/acked_writes_test.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/idempotent_dedup_test.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/antithesis/idempotent_dedup_test.py | 21 | # producer restarts. Old PIDs expire between rounds, exercising the | COMMENT |
| LOW | tests/rptest/antithesis/random_ops_smoke_test.py | 1 | # Copyright 2026 Redpanda Data, Inc. | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 141 | msg_rate_limit: int = 0 | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 281 | # timestamp for last message | COMMENT |
| LOW | …sts/rptest/remote_scripts/cloud/aws_eks_token_cache.sh | 1 | #!/bin/bash | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1181 | COMMENT | |
| LOW | tests/rptest/tests/cluster_features_test.py | 1421 | got = sum(1 for line in consumed.splitlines() if line) | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1941 | self.redpanda.stop_node(victim) | COMMENT |
| LOW | tests/rptest/tests/cluster_config_test.py | 201 | # Since we skip RedpandaService.start, must clean node explicitly | COMMENT |
| LOW | tests/rptest/tests/cluster_config_test.py | 301 | COMMENT | |
| LOW | tests/rptest/tests/__init__.py | 1 | # Copyright 2020 Redpanda Data, Inc. | COMMENT |
| 1143 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/redpanda-gdb.py | 555 | except Exception as exc: | CODE |
| LOW | tools/redpanda-gdb.py | 563 | except Exception as exc: | CODE |
| LOW | tools/redpanda-gdb.py | 941 | except Exception as e: | CODE |
| LOW | tools/redpanda-gdb.py | 2182 | except Exception as e: | CODE |
| MEDIUM | tools/redpanda-gdb.py | 929 | def get_text_range(): | CODE |
| LOW | tools/dev_cluster.py | 160 | except Exception: | CODE |
| LOW | tools/dev_cluster.py | 656 | except Exception as e: | CODE |
| MEDIUM | tools/dev_cluster.py | 154 | def cpuset_hardware_core_count() -> int: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 218 | except Exception as e: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 377 | except Exception as e: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 492 | except Exception as e: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 611 | except Exception as e: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 770 | except Exception as e: | CODE |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 1119 | except Exception as e: | CODE |
| LOW | tools/pgo_bolt/train_pgo.py | 357 | except Exception as e: | CODE |
| MEDIUM | tools/pgo_bolt/train_pgo.py | 358 | print(f"Error terminating {name}: {e}") | CODE |
| LOW | tools/build-perf/build-timer.py | 84 | except Exception as read_exc: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 126 | except Exception as e: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 202 | except Exception as e: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 214 | except Exception as e: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 432 | except Exception as e: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 459 | except Exception: | CODE |
| LOW | tests/rp_cloud_cleanup.py | 500 | except Exception: | CODE |
| LOW | tests/rptest/util.py | 647 | except Exception: | CODE |
| LOW | tests/rptest/util.py | 727 | except Exception as e: | STRING |
| MEDIUM | tests/rptest/util.py | 609 | def check_throttle_rate(node): | CODE |
| LOW | tests/rptest/clients/rpk.py | 943 | except Exception: | CODE |
| LOW | tests/rptest/clients/rpk.py | 1075 | except Exception: | CODE |
| MEDIUM | tests/rptest/clients/rpk.py | 415 | def create_topic() -> tuple[bool, str] | bool: | CODE |
| MEDIUM | tests/rptest/clients/rpk.py | 1069 | def try_describe_group(group): | CODE |
| LOW | tests/rptest/clients/python_librdkafka.py | 87 | except Exception as e: | CODE |
| LOW | tests/rptest/clients/python_librdkafka.py | 192 | except Exception as e: | CODE |
| LOW | tests/rptest/clients/rp_storage_tool.py | 36 | except Exception as e: | CODE |
| LOW | tests/rptest/clients/kcl.py | 570 | except Exception: | CODE |
| LOW | tests/rptest/clients/kubectl.py | 550 | except Exception: | CODE |
| LOW | tests/rptest/clients/kubectl.py | 616 | except Exception as e: | CODE |
| LOW | …s/rptest/infinite_retention/infinite_retention_test.py | 773 | except Exception as exc: | CODE |
| LOW | tests/rptest/infinite_retention/checks.py | 40 | except Exception: | CODE |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 113 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 141 | except Exception as e: | CODE |
| LOW⚡ | tests/rptest/antithesis/consumer_group_test.py | 161 | except Exception as e: | CODE |
| LOW⚡ | tests/rptest/antithesis/consumer_group_test.py | 165 | except Exception as e: | CODE |
| LOW⚡ | tests/rptest/antithesis/consumer_group_test.py | 169 | except Exception: | CODE |
| LOW⚡ | tests/rptest/antithesis/consumer_group_test.py | 173 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 188 | except Exception: | CODE |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 198 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 211 | except Exception as e: | CODE |
| MEDIUM | tests/rptest/antithesis/consumer_group_test.py | 184 | def group_lag_zero() -> bool: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 83 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 146 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 161 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 289 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 311 | except Exception: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 321 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 387 | except Exception: | CODE |
| MEDIUM | tests/rptest/antithesis/antithesis_utils.py | 299 | def _ready() -> bool: | CODE |
| LOW | tests/rptest/antithesis/leader_election_test.py | 104 | except Exception as e: | CODE |
| LOW | tests/rptest/antithesis/leader_election_test.py | 137 | except Exception as e: | CODE |
| LOW⚡ | tests/rptest/antithesis/acked_writes_test.py | 165 | except Exception as e: | CODE |
| LOW⚡ | tests/rptest/antithesis/acked_writes_test.py | 169 | except Exception as e: | CODE |
| 474 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tools/dev_cluster.py | 3 | # ================================================================== | COMMENT |
| MEDIUM | tools/dev_cluster.py | 12 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/ducktape_test_package.py | 7 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/ducktape_test_package.py | 16 | # ================================================================== | COMMENT |
| MEDIUM⚡ | tools/antithesis/single_binary_test_package.py | 7 | # ================================================================== | COMMENT |
| MEDIUM⚡ | tools/antithesis/single_binary_test_package.py | 16 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/at_common.py | 1 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/at_common.py | 10 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/ducktape_deps/ducktape_entrypoint.sh | 3 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/ducktape_deps/ducktape_entrypoint.sh | 12 | # ================================================================== | COMMENT |
| MEDIUM | …/antithesis/ducktape_deps/ducktape_singleton_driver.sh | 3 | # ================================================================== | COMMENT |
| MEDIUM | …/antithesis/ducktape_deps/ducktape_singleton_driver.sh | 12 | # ================================================================== | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 31 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 33 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 40 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 42 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 53 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 55 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 62 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 64 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 69 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 71 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 76 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 78 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 85 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | tools/tests/run_cov_test.sh | 87 | # --------------------------------------------------------------- | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 141 | # ── scripted membership operations ────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 265 | # ── helpers ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 566 | # ── tests ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 760 | # ── first recycle: joiner gets stuck as a raft0 learner ──────────── | COMMENT |
| MEDIUM | tests/rptest/tests/tiered_cloud_local_retention_test.py | 110 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | tests/rptest/tests/tiered_cloud_local_retention_test.py | 112 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/tiered_cloud_local_retention_test.py | 246 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/tiered_cloud_local_retention_test.py | 248 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | tests/rptest/tests/storage_resources_test.py | 270 | # ============ | COMMENT |
| MEDIUM | tests/rptest/tests/storage_resources_test.py | 281 | # ========== | COMMENT |
| MEDIUM | tests/rptest/tests/storage_resources_test.py | 287 | # ============== | COMMENT |
| MEDIUM | tests/rptest/tests/storage_resources_test.py | 299 | # ================ | COMMENT |
| MEDIUM | tests/rptest/tests/cloud_topics/e2e_test.py | 195 | # ── L1 maintenance metric helpers ─────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/cloud_topics/e2e_test.py | 236 | # ── L1 maintenance wait helpers ───────────────────────────────── | COMMENT |
| MEDIUM | …ts/rptest/tests/cloud_topics/compaction_stress_test.py | 57 | # ── Wait helpers ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/cloud_topics/leveling_stress_test.py | 76 | # ── Extent-size helpers ───────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/cloud_topics/leveling_stress_test.py | 93 | # ── Config helpers ────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/cloud_topics/leveling_stress_test.py | 105 | # ── Wait helpers ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/cloud_topics/leveling_stress_test.py | 123 | # ── Workflow helpers ──────────────────────────────────────────── | COMMENT |
| MEDIUM | …est/scale_tests/cloud_topics_maintenance_scale_test.py | 226 | # ── Produce phase: write under concurrent compaction ───────── | COMMENT |
| MEDIUM | …est/scale_tests/cloud_topics_maintenance_scale_test.py | 247 | # ── Wait for compaction to remove duplicates ───────────────── | COMMENT |
| MEDIUM | …ptest/scale_tests/cloud_topics_cold_read_scale_test.py | 248 | # ── Build a backlog larger than the cloud cache ────────────── | COMMENT |
| MEDIUM | …st/cfr_tests/controller_forced_reconfiguration_test.py | 70 | # ── CFR via protobuf API ───────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 36 | # ── Shared data types ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 52 | # ── Predefined timeout presets ─────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 61 | # ── TLS provider ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 95 | # ── Base test class ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 131 | # ── node-id bookkeeping ────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 139 | # ── cluster start ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 158 | # ── node helpers ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 171 | # ── recovery mode ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 203 | # ── leader / liveness checks ───────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 248 | # ── cluster splitting ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/cfr_tests/cfr_test_base.py | 311 | # ── node joining ───────────────────────────────────────────────────── | COMMENT |
| 47 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tools/dev_cluster.py | 356 | # Create a basic Prometheus configuration | COMMENT |
| MEDIUM | tools/type-checking/type-check.py | 251 | # Create a temporary strictness map with only these files at the target level | COMMENT |
| MEDIUM | tests/rptest/tests/node_resize_test.py | 62 | # Create a topic and write some data to make sure the cluster | COMMENT |
| MEDIUM | tests/rptest/tests/rpk_registry_test.py | 108 | # Create the user which rpk will use to authenticate. | COMMENT |
| MEDIUM | tests/rptest/tests/consumer_group_test.py | 2029 | # Create the group on the read replica and force its committed offset | COMMENT |
| MEDIUM | tests/rptest/tests/audit_log_test.py | 2839 | # Create a role in Redpanda with the Keycloak group as a member | COMMENT |
| MEDIUM | tests/rptest/tests/audit_log_test.py | 3794 | # Create a schema in a custom context (materializes the context) | COMMENT |
| MEDIUM | tests/rptest/tests/topic_id_migrator_test.py | 52 | # Create the topics to be migrated | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 929 | # Create a group mapper that includes group membership in the access token. | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 933 | # Create the group and add the service account to it | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 937 | # Create a topic and grant access to it via the group ACL principal. | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1159 | # Create the group and add the service account to it | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1163 | # Create a topic | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1166 | # Create a role and add the group as a member using the v2 Admin API | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1241 | # Create the group and add the service account to it | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1245 | # Create a topic | COMMENT |
| MEDIUM⚡ | tests/rptest/tests/redpanda_oauth_test.py | 1248 | # Create a role with the group as a member | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 950 | # Create a Kafka client that authenticates using OIDC | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 1198 | # Create a Kafka client that authenticates using OIDC | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 1294 | # Create a Kafka client that authenticates using OIDC | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 1340 | # Create a topic | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 1343 | # Create a role with both groups as members | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_oauth_test.py | 1427 | # Create the group and add the service user to it | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 273 | # Create a Group ACL on the cluster resource | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 281 | # Create a Group ACL on a topic resource | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 373 | # Create a user with ACL | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 379 | # Create a role with ACL | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 391 | # Create a group ACL | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 491 | # Create a role with only Group members | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_recovery_test.py | 505 | # Create a role with mixed User and Group members | COMMENT |
| MEDIUM | tests/rptest/tests/rpk_role_test.py | 80 | # Create the role | COMMENT |
| MEDIUM | tests/rptest/tests/rpk_shadow_link_test.py | 58 | # Create a link that mirrors topics, offsets, ACLs and SR. | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1006 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1093 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1706 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 2105 | # Create the users | COMMENT |
| MEDIUM | tests/rptest/tests/log_compaction_test.py | 494 | # Create a topic with `compact` policy, and a min.cleanable.dirty.ratio of 1.0. | COMMENT |
| MEDIUM | …s/rptest/tests/partition_force_reconfiguration_test.py | 831 | # Create a mix of rf=1 and 3 topics. | COMMENT |
| MEDIUM | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 1685 | # Create a cloud topic and a normal topic on the source | COMMENT |
| MEDIUM | tests/rptest/tests/consumer_offsets_batch_cache_test.py | 42 | # Create a consumer that will commit random offsets without consuming | COMMENT |
| MEDIUM | tests/rptest/tests/services_self_test.py | 879 | # Create a unique error message that we can search for | COMMENT |
| MEDIUM | tests/rptest/tests/throughput_limits_snc_test.py | 26 | # This file is about throughput limiting that works at shard/node/cluster (SNC) | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 3254 | # Create a topic with incorrect strategy | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 6201 | # Create a context by creating and then deleting all schemas | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 6436 | # Create a subject | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 8307 | # Create the users | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 9236 | # Define the ACLs | COMMENT |
| MEDIUM | tests/rptest/tests/topic_recovery_test.py | 155 | """This method is invoked after the recovery and partition validation are | STRING |
| MEDIUM | …cluster_linking_schema_registry_write_blocking_test.py | 191 | # Create a shadow link that shadows only the ".prod" context via the | COMMENT |
| MEDIUM | …est/tests/cluster_linking_schema_registry_sync_test.py | 216 | # Create a shadow link that syncs only the Schema Registry, in API mode, | COMMENT |
| MEDIUM | tests/rptest/tests/data_migrations_api_test.py | 1543 | # Create a cloud topic | COMMENT |
| MEDIUM | tests/rptest/tests/upgrade_test.py | 497 | # Create a topic with small local retention | COMMENT |
| MEDIUM | tests/rptest/tests/timequery_test.py | 134 | # Create a topic and produce a run of messages we will query. | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_linking_e2e_test.py | 3412 | # Create a Group ACL on the source cluster | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_linking_e2e_test.py | 3900 | # Create a link pointing to the old source cluster | COMMENT |
| MEDIUM | tests/rptest/tests/shard_placement_test.py | 247 | # Create a cluster that doesn't support node-local core assignment yet | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_kerberos_test.py | 136 | # Create a topic that's visible to "client" iff acl = True | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_kerberos_test.py | 149 | # Create a topic visible to anybody | COMMENT |
| MEDIUM | tests/rptest/tests/redpanda_kerberos_test.py | 457 | # Create a topic that's visible to "client" iff acl = True | COMMENT |
| MEDIUM | tests/rptest/tests/openssl_config_test.py | 104 | # Create a client certificate for testing TLS connections | STRING |
| 25 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/redpanda-gdb.py | 2832 | CODE | |
| LOW | tools/redpanda-gdb.py | 3416 | CODE | |
| LOW | tools/dev_cluster.py | 635 | CODE | |
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 505 | CODE | |
| LOW | tools/antithesis/ducktape_test_package.py | 169 | CODE | |
| LOW | tools/antithesis/single_binary_test_package.py | 341 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 141 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 275 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 294 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 311 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 364 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 92 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 405 | CODE | |
| LOW | tools/offline_log_viewer/viewer.py | 225 | CODE | |
| LOW | tools/offline_log_viewer/controller.py | 443 | CODE | |
| LOW | tools/offline_log_viewer/controller.py | 552 | CODE | |
| LOW | tools/offline_log_viewer/controller.py | 967 | CODE | |
| LOW | tools/offline_log_viewer/model.py | 268 | CODE | |
| LOW | tools/offline_log_viewer/model.py | 309 | CODE | |
| LOW | tools/offline_log_viewer/storage.py | 60 | CODE | |
| LOW | tools/offline_log_viewer/kafka.py | 60 | CODE | |
| LOW | tools/offline_log_viewer/consumer_offsets.py | 194 | CODE | |
| LOW | tools/offline_log_viewer/consumer_offsets.py | 212 | CODE | |
| LOW | tools/offline_log_viewer/tx_coordinator.py | 22 | CODE | |
| LOW | tools/consumer_offsets_recovery/main.py | 35 | CODE | |
| LOW | tools/build-perf/build-timer.py | 59 | CODE | |
| LOW | tools/type-checking/type-check.py | 325 | CODE | |
| LOW | tools/type-checking/type-check.py | 381 | CODE | |
| LOW | tools/type-checking/type-check.py | 498 | CODE | |
| LOW | tools/type-checking/type-check.py | 578 | CODE | |
| LOW | tools/type-checking/type-check.py | 658 | CODE | |
| LOW | tools/metrics-mock/metrics-parser.py | 128 | CODE | |
| LOW | tools/metrics-mock/metrics-mock.py | 322 | CODE | |
| LOW | tools/metrics-mock/metrics-mock.py | 198 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 686 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 130 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 250 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 272 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 467 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 586 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 505 | CODE | |
| LOW | tests/rp_cloud_cleanup.py | 531 | CODE | |
| LOW | tests/rptest/trim_results.py | 35 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 267 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1036 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1043 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1102 | CODE | |
| LOW | tests/rptest/clients/ping_pong.py | 155 | CODE | |
| LOW | tests/rptest/clients/kubectl.py | 24 | CODE | |
| LOW | …s/rptest/infinite_retention/infinite_retention_test.py | 477 | CODE | |
| LOW | tests/rptest/remote_scripts/topic_operations.py | 86 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 1389 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 454 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 648 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 819 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 969 | CODE | |
| LOW | tests/rptest/remote_scripts/compute_storage.py | 131 | CODE | |
| LOW | tests/rptest/remote_scripts/compute_storage.py | 164 | CODE | |
| LOW | tests/rptest/chaos_tests/single_fault_test.py | 160 | CODE | |
| LOW | tests/rptest/tests/consumer_group_test.py | 179 | CODE | |
| 218 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | tests/rptest/tests/cluster_features_test.py | 1504 | req.shadow_link.configurations.client_options.bootstrap_servers.extend( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 191 | shadow_link_req.shadow_link.configurations.topic_metadata_sync_options.auto_create_shadow_topic_filters.extend( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 311 | shadow_link_req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.append( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 405 | shadow_link.configurations.client_options.authentication_configuration.scram_configuration.CopyFrom( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 518 | shadow_link.configurations.client_options.authentication_configuration.plain_configuration.CopyFrom( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 1022 | create_link.shadow_link.configurations.schema_registry_sync_options.shadow_schema_registry_topic.CopyFrom( | CODE |
| CRITICAL | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 1376 | shadow_link.configurations.client_options.authentication_configuration.scram_configuration.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/shadow_link_role_sync_test.py | 401 | req.shadow_link.configurations.client_options.authentication_configuration.scram_configuration.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/shadow_link_sr_preflight_test.py | 70 | req.shadow_link.configurations.schema_registry_sync_options.shadow_schema_registry_api.CopyFrom( | CODE |
| CRITICAL | …est/tests/cluster_linking_schema_registry_sync_test.py | 245 | req.shadow_link.configurations.schema_registry_sync_options.shadow_schema_registry_api.CopyFrom( | CODE |
| CRITICAL⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 306 | link_request.shadow_link.configurations.topic_metadata_sync_options.interval.CopyFrom( | CODE |
| CRITICAL⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 309 | link_request.shadow_link.configurations.consumer_offset_sync_options.interval.CopyFrom( | CODE |
| CRITICAL⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 312 | link_request.shadow_link.configurations.security_sync_options.interval.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 230 | create_req.shadow_link.configurations.schema_registry_sync_options.shadow_schema_registry_api.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 1363 | bad_link_request.shadow_link.configurations.client_options.tls_settings.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 2585 | req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.extend( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 4395 | req.shadow_link.configurations.topic_metadata_sync_options.start_at_earliest.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 4399 | req.shadow_link.configurations.topic_metadata_sync_options.start_at_latest.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 4414 | req.shadow_link.configurations.topic_metadata_sync_options.start_at_timestamp.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/cluster_linking_e2e_test.py | 4629 | req.shadow_link.configurations.topic_metadata_sync_options.start_at_timestamp.CopyFrom( | CODE |
| CRITICAL | tests/rptest/tests/shadow_linking_rnot_test.py | 497 | req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.append( | CODE |
| CRITICAL | tests/rptest/archival/abs_client.py | 7 | from azure.core.exceptions import ResourceExistsError | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/bazel-tools/support/bazel-tool-trampoline.sh | 67 | # opportunistically refresh the cache; on lock-held (exit 9) just use the | COMMENT |
| MEDIUM | tools/rp_storage_tool/src/bucket_reader.rs | 62 | // use. If this vector is empty, then `segment_objects` may be treated as a robust | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 425 | # For produce only mode just set them to the same value | COMMENT |
| LOW | tests/rptest/remote_scripts/compute_storage.py | 143 | # truncated segment and hence we can just use filesize otherwise | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_features_test.py | 1433 | # 2. Extend the harness to perform CHAINED unfinalized upgrades: an | COMMENT |
| MEDIUM | tests/rptest/tests/cluster_features_test.py | 1437 | # Keep older step functions and their harness coverage for as long as the | COMMENT |
| MEDIUM | tests/rptest/tests/nodes_decommissioning_test.py | 202 | # use admin API to leverage the retry policy when controller returns 503 | COMMENT |
| MEDIUM | tests/rptest/tests/scaling_up_test.py | 458 | # shadow indexing is required when we want to leverage fast partition movements | COMMENT |
| MEDIUM | tests/rptest/tests/scaling_up_test.py | 569 | # shadow indexing is required when we want to leverage fast partition movements | COMMENT |
| MEDIUM | tests/rptest/tests/schema_registry_test.py | 9298 | """Test comprehensive ACL validation including control characters, invalid input values and invalid value combin | STRING |
| MEDIUM⚡ | tests/rptest/tests/data_migrations_api_test.py | 570 | time.sleep(2) # make sure test harness can see Redpanda is live | CODE |
| MEDIUM | tests/rptest/tests/datalake/cluster_restore_test.py | 470 | # To make this test more robust, on top of lowering the upload | STRING |
| MEDIUM | tests/rptest/tests/datalake/cluster_restore_test.py | 586 | # To make this test more robust, on top of lowering the upload | STRING |
| LOW | …sts/rptest/redpanda_cloud_tests/omb_validation_test.py | 376 | # on an idle T7 cluster. So we just use a SWAG of 100 + 2% of the connection target as the | COMMENT |
| MEDIUM | …rptest/scale_tests/tiered_storage_cache_stress_test.py | 318 | # 2x margin to make the test robust: if this _still_ fails, something is up. | COMMENT |
| LOW | tests/rptest/e2e_tests/workload_manager.py | 48 | # just add it to processing | COMMENT |
| LOW | …rptest/e2e_tests/workloads/flink_transactions_scale.py | 257 | # No config path provided, just use defaults | COMMENT |
| LOW | …/e2e_tests/workloads/flink_table_transactions_basic.py | 420 | # No config path provided, just use defaults | COMMENT |
| LOW | …/e2e_tests/workloads/flink_transactions_topic_swarm.py | 275 | # No config path provided, just use defaults | COMMENT |
| LOW | tests/rptest/e2e_tests/workloads/flink_consume_basic.py | 154 | # No config path provided, just use defaults | COMMENT |
| LOW | tests/rptest/e2e_tests/workloads/flink_produce_basic.py | 152 | # No config path provided, just use defaults | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1031 | # duplicate Peering connection, just return existing one. | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1534 | # Will just return existing one | COMMENT |
| MEDIUM | tests/rptest/services/tls.py | 74 | # the entire configuration file. It may also hold settings pertaining to more | COMMENT |
| MEDIUM | tests/rptest/services/tls.py | 167 | # the entire configuration file. It may also hold settings pertaining to more | COMMENT |
| LOW | tests/rptest/services/cluster.py | 243 | # and for any more complicated type, you can just pass a string identifier | COMMENT |
| LOW | tests/rptest/services/kafka.py | 61 | # KafkaService does not have such checks, so we just call the original wait_until_with_progress_check function | COMMENT |
| MEDIUM⚡ | .github/workflows/buf.yml | 39 | # Job: validate (push, merge_group, and pull_request - comprehensive validation) | COMMENT |
| MEDIUM | src/v/cluster/commands.h | 110 | key_t key; // we use key to leverage kafka key based compaction | CODE |
| MEDIUM | src/v/cluster/commands.h | 570 | /// leverage the log compactions (i.e only last command for given key is enough | COMMENT |
| MEDIUM | src/v/storage/batch_cache.h | 482 | /// 1. Dirty offsets are monotonic (an assumption we also leverage for | COMMENT |
| MEDIUM | src/v/kafka/protocol/schemata/generator.py | 30 | # - Build a more robust way to define messages and their contents as | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tests/rptest/tests/cluster_features_test.py | 2053 | # Step 1: bootstrap a fresh 2-node cluster reporting v_old. | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2069 | # Step 2: add 3 new nodes reporting v_high. Their earliest | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2104 | # Step 3: decommission both v_old nodes via a v_high node, | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2125 | # Step 4: with both v_old nodes gone, cluster_version must | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2348 | # Step 4: Create a new Shadow Link on the Shadow Cluster | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2352 | # Step 5: Wait for the shadow topic to be created on the Shadow Cluster | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2360 | # Step 6: Verify that the start offset and HWM of all shadow partitions match the source partitions | COMMENT |
| LOW | tests/rptest/tests/cluster_linking_e2e_test.py | 2291 | # Step 2: Write data to the topic across all partitions | COMMENT |
| LOW | tests/rptest/tests/cluster_linking_e2e_test.py | 2316 | # Step 3: Trim the prefix of each partition to its HWM | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 524 | # Step 3: write the seek file on the local filesystem (rpk runs | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 530 | # Step 4: seek the real group via --to-file (epoch=-1 hardcoded). | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 541 | # Step 5: always clean up the throwaway group, even on failure. | COMMENT |
| LOW | tests/rptest/tests/list_offsets_epoch_test.py | 494 | # Step 1: seek the throwaway group to start. | COMMENT |
| LOW | tests/rptest/tests/list_offsets_epoch_test.py | 507 | # Step 2: read the committed offset back from the throwaway group. | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 25 | ### Step 1: Baseline Coverage | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 41 | ### Step 2: Understand the Code | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 56 | ### Step 3: Write Tests | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 72 | ### Step 4: Verify Build | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 80 | ### Step 5: Verify Coverage | COMMENT |
| LOW | .claude/skills/improve-coverage/SKILL.md | 100 | ### Step 6: Summary | COMMENT |
| LOW | src/go/rpk/pkg/cli/plugin_cmds.go | 55 | // Step 1: we install the plugin into our existing command space. | COMMENT |
| LOW | src/go/rpk/pkg/cli/plugin_cmds.go | 116 | // Step 2: we exec the plugin with --help-autocomplete and we install | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1670 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1674 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1678 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1957 | // Step 1: Convert config to cloud ShadowLink proto (simulating what the API returns) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1972 | // Step 2: Convert cloud ShadowLink proto back to config | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1976 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2078 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2082 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2086 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW⚡ | src/transform-sdk/rust/core-types/src/lib.rs | 47 | /// NOTE: This method is useful for tests to mock out custom events to your transform function. | COMMENT |
| LOW⚡ | src/transform-sdk/rust/core-types/src/lib.rs | 55 | /// NOTE: This method is useful for tests to mock out custom events to your transform function. | COMMENT |
| LOW⚡ | src/transform-sdk/rust/core-types/src/lib.rs | 65 | /// NOTE: This method is useful for tests to mock out custom events to your transform function. | COMMENT |
| LOW | src/v/cloud_topics/level_zero/common/producer_queue.h | 45 | // NOTE: This class' memory usage is bounded by the concurrency of in flight | COMMENT |
| LOW | src/v/serde/json/writer.h | 20 | // NOTE: This class is easily misused, it's recommended to use a DOM version | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 520 | # Check if process is still running | COMMENT |
| LOW | tools/type-checking/type-check.py | 511 | # Check if this section is sorted | COMMENT |
| LOW | tools/type-checking/type-check.py | 606 | # Check if this pattern matches any of the files being moved | COMMENT |
| LOW | tests/local_venv.sh | 28 | # Check if venv is up to date | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 50 | # Check if rpk present | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 173 | # Check if provider is the same | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 495 | # Check if network exists in CloudV2 | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 520 | # Check if network exists in CloudV2 | COMMENT |
| LOW | tests/rp_cloud_cleanup.py | 540 | # Check if network exists in CloudV2 | COMMENT |
| LOW | tests/rptest/clients/kubectl.py | 546 | # Check if such pod exists | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 483 | # Check if consumed totals had changed | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 716 | # Check if there is validation needed | COMMENT |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 744 | # Increment index | COMMENT |
| LOW | …sts/rptest/remote_scripts/cloud/aws_eks_token_cache.sh | 19 | # Check if cached token is valid and has >10s remaining | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 287 | # Set back to v0 for sanity check | COMMENT |
| LOW | tests/rptest/tests/tiered_storage_model.py | 1522 | # Set retention to very small value to trigger size based retention | COMMENT |
| LOW | tests/rptest/tests/log_compaction_test.py | 387 | # Set log_retention_ms to an arbitrarily tiny value and wait for log truncation. | COMMENT |
| LOW | tests/rptest/tests/license_upgrade_test.py | 201 | # Set controller to the upgraded node | COMMENT |
| LOW | tests/rptest/tests/flink_basic_test.py | 97 | # Check if data_type list provides correct number of types | COMMENT |
| LOW | …s/rptest/tests/shadow_indexing_compacted_topic_test.py | 91 | # Set compaction to happen infrequently initially, so we have several log segments. | COMMENT |
| LOW | tests/rptest/tests/timequery_test.py | 582 | # Set timeout to 0 to prevent the cloud storage housekeeping from | COMMENT |
| LOW | tests/rptest/tests/topic_delete_test.py | 508 | # Set retention to 5MB | COMMENT |
| LOW | tests/rptest/scale_tests/large_messages_test.py | 220 | # Set properties to allow for more than just the obligatory read to be returned. | COMMENT |
| LOW | tests/rptest/scale_tests/datalake_scale_test.py | 200 | # Set properties to allow for more than just the obligatory read to be returned. | COMMENT |
| LOW⚡ | tests/rptest/e2e_tests/flink_scale_test.py | 124 | # Check if metrics received | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 879 | # Check if panda-proxy is available | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 999 | # Check if cluster is healthy | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1084 | # Check if this is a BYOC and delete agent | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1312 | # Check if this route is already exists in this table | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1371 | # Check if such peering exists | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1460 | # Check if such peering exists | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1539 | # Check if this is active already | COMMENT |
| LOW | tests/rptest/services/databricks_workspace.py | 160 | # Verify if catalog was created successfully and only then delete. | COMMENT |
| LOW | tests/rptest/services/utils.py | 224 | # Check if this line holds error | COMMENT |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 82 | # Check if succeded | COMMENT |
| LOW | tests/rptest/services/redpanda_installer.py | 402 | # Check if someone else already acquired lock and populated | COMMENT |
| LOW | tests/rptest/services/redpanda.py | 2471 | # Check if stored pod and loaded one is the same | COMMENT |
| LOW | tests/rptest/services/redpanda.py | 2476 | # Check if container inside pod stayed the same | COMMENT |
| LOW | tests/rptest/services/provider_clients/ec2_client.py | 271 | # Check if this is RouteAlreadyExists | COMMENT |
| LOW | .github/workflows/dispatch-docs-updates.yml | 37 | # Check if this is the latest release | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | tests/rptest/tests/cluster_features_test.py | 2053 | # Step 1: bootstrap a fresh 2-node cluster reporting v_old. | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2069 | # Step 2: add 3 new nodes reporting v_high. Their earliest | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2104 | # Step 3: decommission both v_old nodes via a v_high node, | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2125 | # Step 4: with both v_old nodes gone, cluster_version must | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2348 | # Step 4: Create a new Shadow Link on the Shadow Cluster | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2352 | # Step 5: Wait for the shadow topic to be created on the Shadow Cluster | COMMENT |
| LOW⚡ | tests/rptest/tests/cluster_linking_e2e_test.py | 2360 | # Step 6: Verify that the start offset and HWM of all shadow partitions match the source partitions | COMMENT |
| LOW | tests/rptest/tests/cluster_linking_e2e_test.py | 2291 | # Step 2: Write data to the topic across all partitions | COMMENT |
| LOW | tests/rptest/tests/cluster_linking_e2e_test.py | 2316 | # Step 3: Trim the prefix of each partition to its HWM | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 524 | # Step 3: write the seek file on the local filesystem (rpk runs | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 530 | # Step 4: seek the real group via --to-file (epoch=-1 hardcoded). | COMMENT |
| LOW⚡ | tests/rptest/tests/list_offsets_epoch_test.py | 541 | # Step 5: always clean up the throwaway group, even on failure. | COMMENT |
| LOW | tests/rptest/tests/list_offsets_epoch_test.py | 494 | # Step 1: seek the throwaway group to start. | COMMENT |
| LOW | tests/rptest/tests/list_offsets_epoch_test.py | 507 | # Step 2: read the committed offset back from the throwaway group. | COMMENT |
| LOW | src/go/rpk/pkg/cli/plugin_cmds.go | 55 | // Step 1: we install the plugin into our existing command space. | COMMENT |
| LOW | src/go/rpk/pkg/cli/plugin_cmds.go | 116 | // Step 2: we exec the plugin with --help-autocomplete and we install | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1670 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1674 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1678 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1957 | // Step 1: Convert config to cloud ShadowLink proto (simulating what the API returns) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1972 | // Step 2: Convert cloud ShadowLink proto back to config | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1976 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2078 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2082 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2086 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW | src/v/model/fundamental.h | 275 | /// The purpose of this function is to mark every place where we converting | COMMENT |
| LOW | src/v/model/fundamental.h | 634 | /// The purpose of this function is to mark every place where we converting | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tests/rptest/tests/tiered_storage_model.py | 120 | self.__solver.push() | CODE |
| HIGH | tests/rptest/tests/cloud_storage_inventory_test.py | 113 | f"test -d {self.inventory_dir} && find {self.inventory_dir} -type f || true" | CODE |
| HIGH | tests/rptest/tests/schema_registry_test.py | 1906 | These are not supported, but if they're null, we let it pass. | STRING |
| HIGH | tests/rptest/tests/sasl_reauth_test.py | 108 | Tests that kafka_sasl_max_reauth_ms{null} produces original behavior | STRING |
| HIGH | tests/rptest/tests/datalake/datalake_upgrade_test.py | 74 | - Avro optionals (two-field union of [null, <FIELD>]) (was struct, | STRING |
| HIGH | tests/rptest/tuner_integration_tests/net_tuner_test.py | 281 | "umask 077 && rpk redpanda tune net -v", timeout_sec=2 | CODE |
| HIGH | tests/rptest/services/mitmproxy.py | 150 | cmd = f"sudo cat {LOG_PATH} 2>/dev/null || cat {LOG_PATH}" | CODE |
| HIGH | tests/rptest/services/redpanda_installer.py | 758 | relink_cmd = f"unlink /opt/redpanda && ln -s {version_root} /opt/redpanda" | CODE |
| HIGH | src/transform-sdk/js/package_toolchain.py | 8 | /bin/bash -c 'apt update && apt install -y git && cmake --preset release-static && cmake --build --preset release-stat | STRING |
| HIGH | src/v/lsm/db/tests/logs_to_trace.py | 396 | let currentShard = null; | CODE |
| HIGH | src/v/lsm/db/tests/logs_to_trace.py | 614 | if (e.target === container || e.target === timeline || e.target.classList.contains('row-content')) {{ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tests/rptest/tests/rpk_registry_test.py | 0 | syntax = "proto3"; message simple { string id = 1; } | STRING |
| HIGH | …sts/rptest/tests/cluster_linking_topic_syncing_test.py | 0 | syntax = "proto3"; message simple { string id = 1; } | STRING |
| HIGH | tests/rptest/tests/schema_registry_test.py | 0 | syntax = "proto3"; message simple { string id = 1; } | STRING |
| HIGH | tests/rptest/services/kgo_verifier_services.py | 0 | for debugging issues around starting and stopping processes: log which processes are running and which ports are in use. | STRING |
| HIGH | tests/rptest/services/kgo_repeater_service.py | 0 | for debugging issues around starting and stopping processes: log which processes are running and which ports are in use. | STRING |
| HIGH | tests/rptest/services/redpanda.py | 0 | for debugging issues around starting and stopping processes: log which processes are running and which ports are in use. | STRING |
| HIGH | tests/rptest/services/kgo_verifier_services.py | 0 | wait for the remote processes http endpoint to come up | STRING |
| HIGH | tests/rptest/services/transform_verifier_service.py | 0 | wait for the remote processes http endpoint to come up | STRING |
| HIGH | tests/rptest/services/kgo_repeater_service.py | 0 | wait for the remote processes http endpoint to come up | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/type-checking/type-check.py | 162 | CODE | |
| LOW | tests/rptest/util.py | 149 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 710 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 975 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1264 | CODE | |
| LOW | tests/rptest/clients/types.py | 146 | CODE | |
| LOW | …ptest/remote_scripts/python_librdkafka_serde_client.py | 170 | CODE | |
| LOW | tests/rptest/remote_scripts/stream_verifier_txn.py | 1040 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 132 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 136 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 140 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 333 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 352 | CODE | |
| LOW | tests/rptest/tests/schema_registry_test.py | 1443 | CODE | |
| LOW | tests/rptest/tests/cluster_linking_test_base.py | 199 | CODE | |
| LOW | tests/rptest/tests/end_to_end.py | 81 | CODE | |
| LOW | tests/rptest/tests/shadow_linking_rnot_test.py | 54 | CODE | |
| LOW | tests/rptest/tests/security_report_test.py | 245 | CODE | |
| LOW | tests/rptest/services/redpanda_cloud.py | 1697 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 45 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 748 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 1012 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 1184 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 1274 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 1462 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 1543 | CODE | |
| LOW | tests/rptest/services/admin_ops_fuzzer.py | 607 | CODE | |
| LOW | tests/rptest/services/rpk_benchmark_service.py | 47 | CODE | |
| LOW | tests/rptest/services/producer_swarm.py | 26 | CODE | |
| LOW | tests/rptest/services/kafka_cli_consumer.py | 20 | CODE | |
| LOW | tests/rptest/services/verifiable_consumer.py | 269 | CODE | |
| LOW | tests/rptest/services/rpk_consumer.py | 26 | CODE | |
| LOW | tests/rptest/services/canary_benchmark_service.py | 73 | CODE | |
| LOW | tests/rptest/services/verifiable_producer.py | 97 | CODE | |
| LOW | tests/rptest/services/serde_client.py | 35 | CODE | |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 150 | CODE | |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 159 | CODE | |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 176 | CODE | |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 204 | CODE | |
| LOW | tests/rptest/services/kgo_repeater_service.py | 38 | CODE | |
| LOW | tests/rptest/services/kcat_consumer.py | 41 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 617 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 2731 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 3379 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 3872 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/offline_log_viewer/consumer_groups.py | 4 | CODE | |
| LOW | tools/offline_log_viewer/kvstore.py | 9 | CODE | |
| LOW | tools/offline_log_viewer/controller.py | 7 | CODE | |
| LOW | tools/offline_log_viewer/consumer_offsets.py | 5 | CODE | |
| LOW | tools/benchcmp_impl/benchcmp.py | 40 | CODE | |
| LOW | tests/rptest/util.py | 38 | CODE | |
| LOW | tests/rptest/clients/admin/google/api/field_info_pb2.py | 9 | CODE | |
| LOW | …/rptest/clients/admin/google/api/field_behavior_pb2.py | 9 | CODE | |
| LOW | tests/rptest/clients/admin/google/api/resource_pb2.py | 9 | CODE | |
| LOW | tests/rptest/antithesis/consumer_group_test.py | 23 | CODE | |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 15 | CODE | |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 36 | CODE | |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 36 | CODE | |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 36 | CODE | |
| LOW | tests/rptest/antithesis/antithesis_utils.py | 36 | CODE | |
| LOW | tests/rptest/antithesis/leader_election_test.py | 29 | CODE | |
| LOW | tests/rptest/antithesis/acked_writes_test.py | 28 | CODE | |
| LOW | tests/rptest/antithesis/idempotent_dedup_test.py | 34 | CODE | |
| LOW | tests/rptest/antithesis/random_ops_smoke_test.py | 16 | CODE | |
| LOW | tests/rptest/remote_scripts/stub_oidc_provider.py | 1 | CODE | |
| LOW | tests/rptest/remote_scripts/payload_pb2.py | 14 | CODE | |
| LOW | tests/rptest/tests/gbac_claim_test.py | 1 | CODE | |
| LOW | tests/rptest/services/kgo_verifier_services.py | 10 | CODE | |
| LOW | tests/rptest/services/rpk_benchmark_service.py | 10 | CODE | |
| LOW | tests/rptest/services/stub_oidc_provider.py | 1 | CODE | |
| LOW | tests/rptest/services/canary_benchmark_service.py | 10 | CODE | |
| LOW | tests/rptest/services/rolling_restarter.py | 19 | CODE | |
| LOW | tests/rptest/services/redpanda_installer.py | 28 | CODE | |
| LOW | tests/rptest/services/chaos/faults/all.py | 13 | CODE | |
| LOW | tests/rptest/services/chaos/faults/all.py | 13 | CODE | |
| LOW | tests/rptest/services/chaos/faults/all.py | 13 | CODE | |
| LOW | tests/rptest/services/chaos/faults/all.py | 14 | CODE | |
| LOW | tests/rptest/services/chaos/faults/all.py | 15 | CODE | |
| LOW | tests/rptest/services/chaos/workloads/all.py | 13 | CODE | |
| LOW | tests/rptest/services/chaos/workloads/all.py | 14 | CODE | |
| LOW | tests/rptest/services/chaos/workloads/all.py | 15 | CODE | |
| LOW | src/v/lsm/db/tests/logs_to_trace.py | 17 | CODE | |
| LOW | src/v/iceberg/tests/avro_decimal_interop_gen.py | 22 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tests/rptest/clients/kubectl.py | 243 | Runs kubectl subcommands on a Cloud Agent with streaming stdout and stderr to output Args: | STRING |
| HIGH | tests/rptest/remote_scripts/stream_verifier_txn.py | 649 | Consumes all messages from topic Args: logger (logging.Logger): logger class topic (Top | STRING |
| HIGH | tests/rptest/services/openmessaging_benchmark.py | 389 | Evaluates the success of a benchmark test based on various metrics and conditions. Parameters: | STRING |
| HIGH | tests/rptest/services/openmessaging_benchmark.py | 449 | Detects and evaluates latency spikes in multiple series of latency data based on predefined thresholds. | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/rp_storage_tool/src/main_unstable.rs | 153 | // TODO: implement binary encoding | COMMENT |
| LOW | tests/rptest/tests/rbac_test_v2.py | 261 | # TODO: Add test_list_role_filter_v2 once v2 list_roles supports filters | COMMENT |
| LOW | tests/rptest/tests/rbac_test_v2.py | 553 | # TODO: Add testing for filtering once v2 list_current_user_roles supports it | COMMENT |
| LOW | tests/rptest/tests/rbac_test_v2.py | 711 | # TODO: Add test_rbac_group once group role membership honored in authZ (CORE-15199) | COMMENT |
| LOW | tests/rptest/tests/tiered_storage_model.py | 797 | # TODO: implement log based validator | COMMENT |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 149 | # TODO: Handle errors | COMMENT |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 158 | # TODO: Handle errors | COMMENT |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 175 | # TODO: Handle errors | COMMENT |
| LOW | tests/rptest/services/cloud_cluster_utils.py | 203 | # TODO: Handle errors | COMMENT |
| LOW⚡ | tests/rptest/services/provider_clients/ec2_client.py | 252 | # TODO: Handle errors | COMMENT |
| LOW⚡ | tests/rptest/services/provider_clients/ec2_client.py | 257 | # TODO: Handle errors | COMMENT |
| LOW | src/v/cluster/distributed_kv_stm.h | 170 | // TODO: implement delete retention with incremental raft snapshots. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …d_reconfiguration/invoke_controller_reconfiguration.py | 85 | logger = logging.getLogger(__name__) | STRING |
| LOW | tests/rptest/context/gcp.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | tests/rptest/tests/throttled_raft0_test.py | 1234 | def _set_recovery_rate(self, rate: int) -> None: | CODE |
| LOW | tests/rptest/tests/shadow_link_role_sync_test.py | 117 | def _set_role_sync_paused(self, paused: bool) -> None: | CODE |
| LOW | tests/rptest/tests/cluster_linking_e2e_test.py | 1991 | def update_link_config(include: bool) -> None: | CODE |
| LOW | tests/rptest/tests/full_disk_test.py | 79 | def _setup(self) -> None: | CODE |
| LOW | tests/rptest/scale_tests/large_messages_test.py | 359 | def _setup_mode(self, mode: Mode) -> None: | CODE |
| LOW | tests/rptest/scale_tests/large_messages_test.py | 378 | def _setup_topic_names(self, topic_prefix: str) -> None: | CODE |
| LOW | tests/rptest/services/mitmproxy.py | 54 | def set_server_cert(self, cert) -> None: | CODE |
| LOW | tests/rptest/services/mitmproxy.py | 61 | def set_proxy_auth(self, username: str, password: str) -> None: | CODE |
| LOW | tests/rptest/services/storage.py | 94 | def set_segment_size(self, segment_name: str, size: int) -> None: | CODE |
| LOW | tests/rptest/services/redpanda.py | 1064 | def set_expected_damage(self, damage_types: set[str]) -> None: | CODE |
| LOW | tests/rptest/services/redpanda.py | 4267 | def set_cluster_config_to_null(self, name: str, **kwargs: Any) -> None: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/antithesis/ducktape_test_package.py | 34 | # Usage: | COMMENT |
| LOW⚡ | tools/antithesis/single_binary_test_package.py | 25 | # Usage: | COMMENT |
| LOW | …ols/schema_registry_tools/schemas_command_generator.py | 3 | # Usage: | COMMENT |
| LOW | src/v/http/tests/http_imposter.h | 79 | /// Example usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tests/rptest/tests/cluster_config_test.py | 308 | rp_conf["cluster_id"] = "placeholder" | CODE |
| LOW | src/go/rpk/pkg/serde/proto_test.go | 743 | "addressLines": ["123 Main St", "Suite 456"] | CODE |
| LOW | src/transform-sdk/rust/examples/jaq/README.md | 16 | echo '{"data":9,"email":"foo@bar.com"}' | rpk topic produce $MY_INPUT_TOPIC | CODE |
| LOW | src/v/redpanda/tests/fixture.h | 260 | security::principal_type::user, "fake-user"}; | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | bazel/clang_tidy/plugins/redpanda_noop_check.h | 19 | * Included for demonstration purposes and so the tool doesn't complain about | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | src/go/rpk/pkg/cli/cluster/connections/list.go | 259 | // TODO: add guardrails and define a proper field mapping | COMMENT |