Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
This report summarizes scanner evidence for redpanda-data/redpanda, a C++ project with 12,600 GitHub stars. SynthScan examined 711,159 lines of code across 3746 source files, recording 4657 pattern matches distributed across 23 syntactic categories. The legacy adjusted pattern signal is 8.2 (Moderate pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 3799 finding(s).
Are imports declared and package/API names verified? 78 finding(s).
Are wrappers, guards, and repeated structures necessary? 2796 finding(s).
Which changes need focused human review? 4657 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 4657 distinct pattern matches across 23 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | 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/bazel_target.py | 191 | 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 |
| 1911 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/bazel_target.py | 1 | #!/usr/bin/python3 | 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/rpk.py | 1101 | def try_describe_group(group): | 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 | 1201 | # across upgrade steps (today only v26.1 -> v26.2). The coverage guard | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1221 | # working after finalize -- by ShadowLinkUnfinalizedUpgradeTest. | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1381 | f"({label}), read {got}" | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1561 | node = self.redpanda.nodes[-1] | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 1901 | # downgrade floor -- to its own latest; the flag rides along in | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2041 | # Attempt to roll a single node back to the old release. The old binary | COMMENT |
| 1198 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tools/redpanda-gdb.py | 929 | def get_text_range(): | CODE |
| 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 |
| 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 |
| MEDIUM | tests/rptest/clients/rpk.py | 425 | def create_topic() -> tuple[bool, str] | bool: | CODE |
| MEDIUM | tests/rptest/clients/rpk.py | 1101 | def try_describe_group(group): | CODE |
| LOW | tests/rptest/clients/rpk.py | 958 | except Exception: | CODE |
| LOW | tests/rptest/clients/rpk.py | 1107 | except Exception: | 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 |
| 480 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | tools/redpanda-gdb.py | 3573 | except StopIteration: | CODE |
| HIGH | tools/redpanda-gdb.py | 2405 | except StopIteration: | CODE |
| HIGH | tools/dev_cluster.py | 160 | except Exception: | CODE |
| HIGH | tools/dev_cluster.py | 190 | except ProcessLookupError: | CODE |
| HIGH | tools/offline_log_viewer/kvstore.py | 401 | except KeyError: | CODE |
| HIGH | tools/offline_log_viewer/viewer.py | 199 | except: | CODE |
| HIGH | tools/pgo_bolt/train_pgo.py | 354 | except ProcessLookupError: | CODE |
| HIGH | tests/rptest/util.py | 746 | except StopIteration: | CODE |
| HIGH | tests/rptest/clients/rpk.py | 958 | except Exception: | CODE |
| HIGH | tests/rptest/clients/kubectl.py | 88 | except KeyError: | CODE |
| HIGH | tests/rptest/infinite_retention/checks.py | 40 | except Exception: | CODE |
| HIGH | tests/rptest/antithesis/consumer_group_test.py | 169 | except Exception: | CODE |
| HIGH | tests/rptest/antithesis/antithesis_utils.py | 159 | except FileNotFoundError: | CODE |
| HIGH | tests/rptest/antithesis/acked_writes_test.py | 173 | except Exception: | CODE |
| HIGH | tests/rptest/antithesis/idempotent_dedup_test.py | 129 | except Exception: | CODE |
| HIGH | tests/rptest/tests/license_enforcement_test.py | 240 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/license_enforcement_test.py | 318 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/license_enforcement_test.py | 375 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/cluster_features_test.py | 489 | except DucktapeTimeoutError: | CODE |
| HIGH | tests/rptest/tests/cluster_features_test.py | 543 | except DucktapeTimeoutError: | CODE |
| HIGH | tests/rptest/tests/node_restart_probe_test.py | 396 | except (StopIteration, AssertionError): | CODE |
| HIGH | tests/rptest/tests/control_character_flag_test.py | 105 | except requests.exceptions.HTTPError: | CODE |
| HIGH | tests/rptest/tests/control_character_flag_test.py | 121 | except requests.exceptions.HTTPError: | CODE |
| HIGH | tests/rptest/tests/control_character_flag_test.py | 131 | except requests.exceptions.HTTPError: | CODE |
| HIGH | tests/rptest/tests/acls_test.py | 552 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 626 | except Exception: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 941 | except requests.HTTPError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 947 | except requests.HTTPError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1267 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1355 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1919 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1976 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1994 | except Exception: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 2044 | except TimeoutError: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 2197 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/audit_log_test.py | 1649 | except Exception as _: | CODE |
| HIGH | tests/rptest/tests/crl_test.py | 322 | except Exception: | CODE |
| HIGH | tests/rptest/tests/scram_test.py | 527 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/scram_test.py | 616 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/tiered_cloud_local_retention_test.py | 552 | except Exception: | CODE |
| HIGH | tests/rptest/tests/cluster_config_test.py | 2434 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/cluster_config_test.py | 2459 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/cluster_config_test.py | 1501 | except RpkException as e: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 532 | except Exception: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 552 | except Exception: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 572 | except Exception: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 596 | except Exception: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 617 | except Exception: | CODE |
| HIGH | tests/rptest/tests/storage_mode_test.py | 1000 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/cluster_bootstrap_test.py | 162 | except Exception: | CODE |
| HIGH | tests/rptest/tests/log_compaction_test.py | 1537 | except Exception: | CODE |
| HIGH | tests/rptest/tests/log_compaction_test.py | 1434 | except Exception: | CODE |
| HIGH | tests/rptest/tests/connection_rate_limit_test.py | 63 | except Exception: | CODE |
| HIGH | tests/rptest/tests/flink_basic_test.py | 219 | except RemoteCommandError: | CODE |
| HIGH | tests/rptest/tests/services_self_test.py | 646 | except CalledProcessError: | CODE |
| HIGH | tests/rptest/tests/services_self_test.py | 980 | except BadLogLines: | CODE |
| HIGH | tests/rptest/tests/debug_bundle_test.py | 334 | except requests.HTTPError: | CODE |
| HIGH | tests/rptest/tests/workload_upgrade_runner_test.py | 131 | except Exception: | CODE |
| HIGH | tests/rptest/tests/schema_registry_test.py | 8602 | except RpkException: | CODE |
| HIGH | tests/rptest/tests/schema_registry_test.py | 8625 | except RpkException: | CODE |
| 51 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/bazel_target.py | 7 | # ================================================================== | COMMENT |
| MEDIUM | tools/antithesis/bazel_target.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 | 273 | # ── helpers ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 582 | # ── tests ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/throttled_raft0_test.py | 776 | # ── 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 | 196 | # ── L1 maintenance metric helpers ─────────────────────────────── | COMMENT |
| MEDIUM | tests/rptest/tests/cloud_topics/e2e_test.py | 237 | # ── 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 | 113 | # Create the user which rpk will use to authenticate. | COMMENT |
| MEDIUM | tests/rptest/tests/consumer_group_test.py | 2161 | # Create the group on the read replica and force its committed offset | COMMENT |
| MEDIUM | tests/rptest/tests/audit_log_test.py | 2840 | # Create a role in Redpanda with the Keycloak group as a member | COMMENT |
| MEDIUM | tests/rptest/tests/audit_log_test.py | 3795 | # 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 | 105 | # Create a link that mirrors topics, offsets, ACLs and SR. | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 506 | # Creating a scheduling group runs a tiny setup task inside the | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1053 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1140 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 1753 | # Create a consumer | COMMENT |
| MEDIUM | tests/rptest/tests/pandaproxy_test.py | 2152 | # 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 | 882 | # 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 | 241 | # 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 |
| 26 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | tests/rptest/tests/cluster_features_test.py | 1468 | req.shadow_link.configurations.client_options.bootstrap_servers.extend( | CODE |
| CRITICAL | …test/tests/cluster_linking_unfinalized_upgrade_test.py | 234 | req.shadow_link.configurations.topic_metadata_sync_options.auto_create_shadow_topic_filters.append( | 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 | 404 | 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 | 275 | 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/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/bazel_target.py | 337 | 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 | 1068 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1075 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1134 | 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 | 192 | CODE | |
| LOW | tests/rptest/tests/consumer_group_test.py | 588 | CODE | |
| 223 more matches not shown… | ||||
| 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 |
| MEDIUM | tests/rptest/clients/rpk.py | 2334 | # because the test harness only wires up the Schema Registry connection, not the admin | 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/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 | 470 | # shadow indexing is required when we want to leverage fast partition movements | COMMENT |
| MEDIUM | tests/rptest/tests/scaling_up_test.py | 592 | # shadow indexing is required when we want to leverage fast partition movements | COMMENT |
| MEDIUM | tests/rptest/tests/rpk_permission_test.py | 135 | # settings, which this harness's authorized+mTLS Kafka listener requires. | 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 | 1059 | # duplicate Peering connection, just return existing one. | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1562 | # 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 | 521 | /// 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 | 2157 | # Step 1: bootstrap a fresh 2-node cluster reporting v_old. | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2173 | # Step 2: add 3 new nodes reporting v_high. Their earliest | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2208 | # Step 3: decommission both v_old nodes via a v_high node, | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2229 | # 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 | 1968 | // Step 1: Convert config to cloud ShadowLink proto (simulating what the API | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1986 | // Step 2: Convert cloud ShadowLink proto back to config | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1990 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2165 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2169 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2173 | // 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 | 288 | # 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 | 885 | # Check if panda-proxy is available | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1027 | # Check if cluster is healthy | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1112 | # Check if this is a BYOC and delete agent | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1340 | # Check if this route is already exists in this table | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1399 | # Check if such peering exists | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1488 | # Check if such peering exists | COMMENT |
| LOW | tests/rptest/services/redpanda_cloud.py | 1567 | # 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 | 2475 | # Check if stored pod and loaded one is the same | COMMENT |
| LOW | tests/rptest/services/redpanda.py | 2480 | # 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 |
|---|---|---|---|---|
| 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_e2e_test.py | 1911 | field (one row has a null), then queries the Iceberg .files metadata | CODE |
| HIGH | tests/rptest/tests/datalake/datalake_e2e_test.py | 2006 | # optional_long: 3 values (including 1 null) → null_value_count=1. | 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 |
|---|---|---|---|---|
| LOW⚡ | tests/rptest/tests/cluster_features_test.py | 2157 | # Step 1: bootstrap a fresh 2-node cluster reporting v_old. | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2173 | # Step 2: add 3 new nodes reporting v_high. Their earliest | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2208 | # Step 3: decommission both v_old nodes via a v_high node, | COMMENT |
| LOW | tests/rptest/tests/cluster_features_test.py | 2229 | # 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 | 1968 | // Step 1: Convert config to cloud ShadowLink proto (simulating what the API | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1986 | // Step 2: Convert cloud ShadowLink proto back to config | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 1990 | // Step 3: Verify the round-trip config matches the original | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2165 | // Step 1: Convert config to proto (config -> proto) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2169 | // Step 2: Convert proto back to config (proto -> config) | COMMENT |
| LOW⚡ | src/go/rpk/pkg/cli/shadow/mapper_test.go | 2173 | // 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/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 | 720 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1004 | CODE | |
| LOW | tests/rptest/clients/rpk.py | 1296 | 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 | 133 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 137 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 141 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 334 | CODE | |
| LOW | tests/rptest/tests/pandaproxy_test.py | 353 | CODE | |
| LOW | tests/rptest/tests/schema_registry_test.py | 1443 | CODE | |
| LOW | tests/rptest/tests/cluster_linking_test_base.py | 203 | 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 | 1725 | 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 | 621 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 2737 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 3387 | CODE | |
| LOW | tests/rptest/services/redpanda.py | 3880 | 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 | 716 | # 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 | 1250 | def _set_recovery_rate(self, rate: int) -> None: | CODE |
| LOW | tests/rptest/tests/shadow_link_role_sync_test.py | 120 | 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 | 1068 | def set_expected_damage(self, damage_types: set[str]) -> None: | CODE |
| LOW | tests/rptest/services/redpanda.py | 4275 | 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 | …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 |