Home / redpanda-data / redpanda
Repository Analysis

redpanda-data/redpanda

7.0 Low AI signal View on GitHub
7.0
Adjusted Score
7.0
Raw Score
100%
Time Factor
—
Last Push
—
Stars
—
Language
667,383
Lines of Code
3614
Files
3952
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 16HIGH 54MEDIUM 280LOW 3602

Pattern Findings

3952 matches across 17 categories. Click a row to expand file-level details.

Hyper-Verbose Identifiers1739 hits · 1589 pts
SeverityFileLineSnippet
LOWtools/redpanda-gdb.py136 def read_kafka_optional_string(self):
LOWtools/redpanda-gdb.py509def absl_insert_version_after_absl(cpp_name):
LOWtools/redpanda-gdb.py626def has_enable_lw_shared_from_this(type):
LOWtools/redpanda-gdb.py736 def external_memory_footprint(self):
LOWtools/redpanda-gdb.py1119def find_cloud_storage_clients(shard=None):
LOWtools/redpanda-gdb.py1264 def batch_cache_index_size_bytes(self):
LOWtools/redpanda-gdb.py1312def get_template_arg_with_prefix(gdb_type, prefix):
LOWtools/redpanda-gdb.py1484 def print_readers_cache_memory(self):
LOWtools/redpanda-gdb.py1615 def print_readers_cache_memory(self):
LOWtools/redpanda-gdb.py3375def get_seastar_memory_start_and_size():
LOWtools/redpanda-gdb.py3402 def is_seastar_allocator_used():
LOWtools/dev_cluster.py154def cpuset_hardware_core_count() -> int:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py505def wait_for_port_forward_ready(process: subprocess.Popen, timeout: int = 30) -> bool:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py645def _summarize_cfr_invocation(cfr_invokers: list[CFRInvoker]) -> None:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py802def _confirm_with_user_or_cancel(prompt: str) -> None:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py809def handle_kubernetes_command(
LOW…d_reconfiguration/invoke_controller_reconfiguration.py847def perform_liveness_check_and_get_cfr_params(
LOW…d_reconfiguration/invoke_controller_reconfiguration.py882def _broker_responses_to_consensus(
LOWtools/antithesis/single_binary_test_package.py202def resolve_and_query_targets(
LOWtools/offline_log_viewer/kvstore.py141def decode_raft_metadata_type(k):
LOWtools/offline_log_viewer/kvstore.py225def decode_offset_translator_key(k):
LOWtools/offline_log_viewer/kvstore.py275def decode_shard_placement_key(k):
LOWtools/offline_log_viewer/kvstore.py335def decode_offset_translator_value(type, v):
LOWtools/offline_log_viewer/viewer.py100 def print_controller_snapshot(self):
LOWtools/offline_log_viewer/viewer.py154 def print_consumer_offsets_summary(self):
LOWtools/offline_log_viewer/controller.py14def read_remote_topic_properties_serde(rdr: Reader):
LOWtools/offline_log_viewer/controller.py42def read_topic_properties_serde(rdr: Reader, version):
LOWtools/offline_log_viewer/controller.py207def read_topic_configuration_assignment_serde(rdr: Reader):
LOWtools/offline_log_viewer/controller.py237def read_property_update_serde(rdr: Reader, type_reader):
LOWtools/offline_log_viewer/controller.py246def read_incremental_topic_update_serde(rdr: Reader):
LOWtools/offline_log_viewer/controller.py411def read_create_partitions_serde(rdr: Reader):
LOWtools/offline_log_viewer/controller.py437def decode_topic_command_serde(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py649def decode_user_command_serde(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py736def decode_serialized_pattern_type(v):
LOWtools/offline_log_viewer/controller.py742def read_acl_binding_filter_serde(k_rdr: Reader):
LOWtools/offline_log_viewer/controller.py834def decode_config_command_serde(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py869def decode_config_command_adl(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py912def decode_feature_command_serde(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py942def decode_feature_command_adl(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py943 def decode_feature_update_action(r):
LOWtools/offline_log_viewer/controller.py961def decode_node_management_command(k_rdr: Reader, rdr: Reader):
LOWtools/offline_log_viewer/controller.py987def decode_user_and_credential(rdr: Reader):
LOWtools/offline_log_viewer/controller.py1004def decode_bootstrap_cluster_cmd_data(rdr: Reader, version):
LOWtools/offline_log_viewer/controller.py1016def decode_cluster_bootstrap_command(k_rdr, rdr):
LOWtools/offline_log_viewer/controller.py1109def read_feature_state_snapshot(rdr: Reader, version: int):
LOWtools/offline_log_viewer/controller.py1126def read_features_table_snapshot(rdr: Reader, version: int):
LOWtools/offline_log_viewer/controller.py1154def read_topic_metadata_fields(rdr: Reader, v: int):
LOWtools/offline_log_viewer/controller.py1164def read_disabled_partitions_set(rdr: Reader, v: int):
LOWtools/offline_log_viewer/controller.py1358 def read_ntp_with_majority_loss(rdr: Reader):
LOWtools/offline_log_viewer/controller.py1398 def read_cluster_metadata_manifest(rdr: Reader, version: int):
LOWtools/offline_log_viewer/controller.py1411 def read_cluster_recovery_state(rdr: Reader, version: int):
LOWtools/offline_log_viewer/model.py38def read_incremental_properties_update(reader):
LOWtools/offline_log_viewer/model.py86def read_unresolved_address_adl(r: Reader):
LOWtools/offline_log_viewer/model.py112def read_broker_properties_adl(r: Reader):
LOWtools/offline_log_viewer/model.py154def read_configuration_update(rdr):
LOWtools/offline_log_viewer/model.py161def decode_configuration_update(rdr: Reader, version: int):
LOWtools/offline_log_viewer/model.py170def read_configuration_update_serde(rdr: Reader):
LOWtools/offline_log_viewer/model.py298def decode_acl_principal_type(p):
LOWtools/offline_log_viewer/model.py377def read_partition_assignment(rdr):
LOWtools/offline_log_viewer/reader.py113 def read_kafka_optional_string(self):
1679 more matches not shown…
Over-Commented Block1102 hits · 1100 pts
SeverityFileLineSnippet
LOWtools/clang-tool-parallel.sh1#!/usr/bin/env bash
LOWtools/duckdb.sh1#!/usr/bin/env bash
LOWtools/redpanda-gdb.py1#!/usr/bin/env python3
LOWtools/dev_cluster.py1#!/usr/bin/python3
LOWtools/dev_cluster.py121 cluster_size: int
LOWtools/check-copyright-year.sh1#!/usr/bin/env bash
LOWtools/spark-sql.sh1#!/usr/bin/env bash
LOW…command_generator/leader_transfer_command_generator.py1#!/usr/bin/env python3
LOWtools/antithesis/ducktape_test_package.py1#!/usr/bin/python3
LOWtools/antithesis/ducktape_test_package.py21# This script:
LOWtools/antithesis/single_binary_test_package.py1#!/usr/bin/python3
LOWtools/antithesis/single_binary_test_package.py21#
LOWtools/antithesis/ducktape_deps/ducktape_entrypoint.sh1#!/usr/bin/env bash
LOW…/antithesis/ducktape_deps/ducktape_singleton_driver.sh1#!/usr/bin/env bash
LOWtools/bazel-tools/support/bazel-tool-trampoline.sh1#!/usr/bin/env bash
LOWtools/rp_storage_tool/src/ntp_mask.rs81 // if let Some(grps) = NTP_MASK_EXPR.captures(input) {
LOWtools/rp_storage_tool/src/bucket_reader.rs161 // // Ambiguous case: two objects at same base offset uploaded in the same term can be:
LOWtools/rp_storage_tool/src/bucket_reader.rs1421 ) -> impl Stream<Item = SegmentStream> + '_ {
LOWtools/rp_storage_tool/src/remote_types.rs281
LOWtools/rp_storage_tool/src/remote_types.rs301 // gauge_col_t _delta_offset_end{};
LOWtools/rp_storage_tool/src/remote_types.rs441 #[serde(skip_serializing_if = "offset_has_default_value")]
LOWtools/tests/run_cov_test.sh1#!/bin/bash
LOW…ols/schema_registry_tools/schemas_command_generator.py1#!/usr/bin/env python3
LOW…ols/schema_registry_tools/schemas_command_generator.py21# 4. Run the generated script above
LOWtools/build-perf/build-timer.py221 # "--strip=never --copt -gline-tables-only",
LOW…cloud_storage_name_mapper/cloud_storage_name_mapper.py1#!/usr/bin/env python3
LOWlicenses/boilerplate.go.txt1// Copyright 2022 Redpanda Data, Inc.
LOWtests/rp_cloud_cleanup.py721
LOW…go/kgo-verifier/pkg/worker/repeater/repeater_worker.go1package loop
LOWtests/antithesis/fixture_test_targets.yml1# Bazel target patterns packaged and submitted to Antithesis by the
LOWtests/rptest/test_suite_fuzz.yml1# Copyright 2025 Redpanda Data, Inc.
LOWtests/rptest/test_suite_pandaproxy.yml1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/test_suite_cloud_self_test.yml1# Copyright 2023 Redpanda Data, Inc.
LOWtests/rptest/__init__.py1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/test_suite_infinite_retention.yml1# Copyright 2023 Redpanda Data, Inc.
LOWtests/rptest/test_suite_nightly.yml1# Copyright 2026 Redpanda Data, Inc.
LOWtests/rptest/test_suite_iceberg_cloud.yml1# Copyright 2025 Redpanda Data, Inc.
LOWtests/rptest/test_suite_chaos.yml1# Copyright 2024 Redpanda Data, Inc.
LOWtests/rptest/test_suite_all.yml1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/test_suite_perf.yml1# Copyright 2022 Redpanda Data, Inc.
LOWtests/rptest/clients/__init__.py1# Copyright 2020 Redpanda Data, Inc.
LOW…s/rptest/infinite_retention/infinite_retention_test.py61 # How much messages should we wait on start
LOWtests/rptest/infinite_retention/checks.py1# Copyright 2023 Redpanda Data, Inc.
LOWtests/rptest/remote_scripts/stream_verifier_txn.py141 msg_rate_limit: int = 0
LOWtests/rptest/remote_scripts/stream_verifier_txn.py281 # timestamp for last message
LOW…sts/rptest/remote_scripts/cloud/aws_eks_token_cache.sh1#!/bin/bash
LOWtests/rptest/tests/__init__.py1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/tests/node_metrics_test.py81 assert all([x >= 0 for x in alerts])
LOWtests/rptest/tests/flink_basic_test.py201 return max_index
LOWtests/rptest/tests/aio_limit_test.py1# Copyright 2025 Redpanda Data, Inc.
LOWtests/rptest/tests/configuration_update_test.py1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/tests/end_to_end.py1# Licensed to the Apache Software Foundation (ASF) under one or more
LOWtests/rptest/tests/topic_delete_test.py641 )
LOWtests/rptest/tests/compatibility/__init__.py1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/tests/cloud_topics/__init__.py1# Copyright 2024 Redpanda Data, Inc.
LOWtests/rptest/tests/datalake/__init__.py1# Copyright 2024 Redpanda Data, Inc.
LOWtests/rptest/tests/datalake/utils.py1# Copyright 2024 Redpanda Data, Inc.
LOWtests/rptest/redpanda_cloud_tests/__init__.py1# Copyright 2020 Redpanda Data, Inc.
LOWtests/rptest/utils/__init__.py1# Copyright 2022 Redpanda Data, Inc.
LOWtests/rptest/utils/scale_parameters.py21 which are scale or performance tests, or which test some system limits need to be "scale aware"
1042 more matches not shown…
Excessive Try-Catch Wrapping475 hits · 536 pts
SeverityFileLineSnippet
LOWtools/redpanda-gdb.py555 except Exception as exc:
LOWtools/redpanda-gdb.py563 except Exception as exc:
LOWtools/redpanda-gdb.py941 except Exception as e:
LOWtools/redpanda-gdb.py2182 except Exception as e:
MEDIUMtools/redpanda-gdb.py929def get_text_range():
LOWtools/dev_cluster.py160 except Exception:
LOWtools/dev_cluster.py656 except Exception as e:
MEDIUMtools/dev_cluster.py154def cpuset_hardware_core_count() -> int:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py218 except Exception as e:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py377 except Exception as e:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py492 except Exception as e:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py611 except Exception as e:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py770 except Exception as e:
LOW…d_reconfiguration/invoke_controller_reconfiguration.py1119 except Exception as e:
LOWtools/pgo_bolt/train_pgo.py357 except Exception as e:
MEDIUMtools/pgo_bolt/train_pgo.py358 print(f"Error terminating {name}: {e}")
LOWtools/build-perf/build-timer.py84 except Exception as read_exc:
LOWtests/rp_cloud_cleanup.py126 except Exception as e:
LOWtests/rp_cloud_cleanup.py202 except Exception as e:
LOWtests/rp_cloud_cleanup.py214 except Exception as e:
LOWtests/rp_cloud_cleanup.py432 except Exception as e:
LOWtests/rp_cloud_cleanup.py459 except Exception:
LOWtests/rp_cloud_cleanup.py500 except Exception:
LOWtests/rptest/util.py572 except Exception:
LOWtests/rptest/util.py652 except Exception as e:
MEDIUMtests/rptest/util.py536def check_throttle_rate(node):
LOWtests/rptest/clients/rpk.py942 except Exception:
LOWtests/rptest/clients/rpk.py1074 except Exception:
MEDIUMtests/rptest/clients/rpk.py414def create_topic() -> tuple[bool, str] | bool:
MEDIUMtests/rptest/clients/rpk.py1068def try_describe_group(group):
LOWtests/rptest/clients/python_librdkafka.py71 except Exception as e:
LOWtests/rptest/clients/python_librdkafka.py176 except Exception as e:
LOWtests/rptest/clients/rp_storage_tool.py36 except Exception as e:
LOWtests/rptest/clients/kcl.py570 except Exception:
LOWtests/rptest/clients/kubectl.py550 except Exception:
LOWtests/rptest/clients/kubectl.py616 except Exception as e:
LOW…s/rptest/infinite_retention/infinite_retention_test.py773 except Exception as exc:
LOWtests/rptest/infinite_retention/checks.py40 except Exception:
LOW…s/rptest/remote_scripts/schema_registry_test_helper.py179 except Exception as e:
MEDIUM…s/rptest/remote_scripts/schema_registry_test_helper.py167def run(self):
LOWtests/rptest/remote_scripts/topic_operations.py396 except Exception as e:
LOWtests/rptest/remote_scripts/stream_verifier_txn.py730 except Exception:
LOWtests/rptest/remote_scripts/stream_verifier_txn.py1423 except Exception as e:
MEDIUMtests/rptest/remote_scripts/stream_verifier_txn.py1389def process_command(command, cfg, ioclass):
LOWtests/rptest/remote_scripts/compute_storage.py260 except Exception:
MEDIUMtests/rptest/remote_scripts/tgkill.py67 print("Error: tgid, tid, and signal must be integers.")
MEDIUMtests/rptest/remote_scripts/tgkill.py73 print(f"Error sending signal: {e}")
LOWtests/rptest/tests/node_resize_test.py52 except Exception as e:
LOWtests/rptest/tests/leadership_transfer_test.py298 except Exception:
MEDIUMtests/rptest/tests/leadership_transfer_test.py294def cluster_healthy() -> bool:
LOWtests/rptest/tests/acls_test.py266 except Exception:
LOWtests/rptest/tests/acls_test.py276 except Exception:
MEDIUMtests/rptest/tests/consumer_group_test.py460def try_list_offsets():
MEDIUMtests/rptest/tests/consumer_group_test.py530def group_is_dead():
MEDIUMtests/rptest/tests/consumer_group_test.py1637def get_summary(node):
LOWtests/rptest/tests/consumer_group_test.py466 except Exception as e:
LOWtests/rptest/tests/consumer_group_test.py592 except Exception as e:
LOWtests/rptest/tests/consumer_group_test.py1269 except Exception as e:
LOWtests/rptest/tests/consumer_group_test.py1508 except Exception as e:
LOWtests/rptest/tests/consumer_group_test.py1640 except Exception as e:
415 more matches not shown…
Decorative Section Separators84 hits · 309 pts
SeverityFileLineSnippet
MEDIUMtools/dev_cluster.py3# ==================================================================
MEDIUMtools/dev_cluster.py12# ==================================================================
MEDIUMtools/antithesis/ducktape_test_package.py7# ==================================================================
MEDIUMtools/antithesis/ducktape_test_package.py16# ==================================================================
MEDIUMtools/antithesis/single_binary_test_package.py7# ==================================================================
MEDIUMtools/antithesis/single_binary_test_package.py16# ==================================================================
MEDIUMtools/antithesis/ducktape_deps/ducktape_entrypoint.sh3# ==================================================================
MEDIUMtools/antithesis/ducktape_deps/ducktape_entrypoint.sh12# ==================================================================
MEDIUM…/antithesis/ducktape_deps/ducktape_singleton_driver.sh3# ==================================================================
MEDIUM…/antithesis/ducktape_deps/ducktape_singleton_driver.sh12# ==================================================================
MEDIUMtools/tests/run_cov_test.sh31# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh33# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh40# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh42# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh53# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh55# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh62# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh64# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh69# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh71# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh76# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh78# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh85# ---------------------------------------------------------------
MEDIUMtools/tests/run_cov_test.sh87# ---------------------------------------------------------------
MEDIUMtests/rptest/tests/storage_resources_test.py270 # ============
MEDIUMtests/rptest/tests/storage_resources_test.py281 # ==========
MEDIUMtests/rptest/tests/storage_resources_test.py287 # ==============
MEDIUMtests/rptest/tests/storage_resources_test.py299 # ================
MEDIUM…ts/rptest/tests/cloud_topics/compaction_stress_test.py58 # ── Metric helpers ──────────────────────────────────────────────
MEDIUM…ts/rptest/tests/cloud_topics/compaction_stress_test.py83 # ── Wait helpers ────────────────────────────────────────────────
MEDIUM…test/scale_tests/cloud_topics_compaction_scale_test.py202 # ── Produce phase: write under concurrent compaction ─────────
MEDIUM…test/scale_tests/cloud_topics_compaction_scale_test.py223 # ── Wait for compaction to remove duplicates ─────────────────
MEDIUM…st/cfr_tests/controller_forced_reconfiguration_test.py70 # ── CFR via protobuf API ─────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py39# ── Shared data types ────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py55# ── Predefined timeout presets ───────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py64# ── TLS provider ─────────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py98# ── Base test class ──────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py134 # ── node-id bookkeeping ──────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py142 # ── cluster start ────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py161 # ── node helpers ─────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py174 # ── recovery mode ────────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py206 # ── leader / liveness checks ─────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py254 # ── cluster splitting ────────────────────────────────────────────────
MEDIUMtests/rptest/cfr_tests/cfr_test_base.py317 # ── node joining ─────────────────────────────────────────────────────
MEDIUM…tests/controller_forced_reconfiguration_script_test.py52# ── CFR script CLI flags ─────────────────────────────────────────────────
MEDIUM…tests/controller_forced_reconfiguration_script_test.py140 # ── helpers ───────────────────────────────────────────────────────────
MEDIUM…tests/controller_forced_reconfiguration_script_test.py306 # ── tests ────────────────────────────────────────────────────────────
MEDIUMtests/rptest/services/flink.py106 # ==============================================================================
MEDIUMtests/rptest/services/flink.py108 # ==============================================================================
MEDIUMtests/rptest/services/redpanda.py2474 # =======================
MEDIUM.github/workflows/buf.yml2# ---------------------------------------------------------------------------
MEDIUM.github/workflows/buf.yml4# ---------------------------------------------------------------------------
MEDIUM.github/workflows/buf.yml8# ---------------------------------------------------------------------------
MEDIUM.github/workflows/buf.yml38# ===========================================================================
MEDIUM.github/workflows/buf.yml40# ===========================================================================
MEDIUM.github/workflows/buf.yml55 # ===========================================================================
MEDIUM.github/workflows/buf.yml57 # ===========================================================================
MEDIUMsrc/go/rpk/pkg/tuners/aio_test.go28# ----------------------------------
MEDIUMsrc/go/rpk/pkg/tuners/thp_test.go71# ----------------------------------
MEDIUMsrc/go/rpk/pkg/tuners/fstrim_test.go107# ----------------------------------
24 more matches not shown…
Self-Referential Comments83 hits · 246 pts
SeverityFileLineSnippet
MEDIUMtools/dev_cluster.py356 # Create a basic Prometheus configuration
MEDIUMtools/type-checking/type-check.py251 # Create a temporary strictness map with only these files at the target level
MEDIUMtests/rptest/tests/node_resize_test.py62 # Create a topic and write some data to make sure the cluster
MEDIUMtests/rptest/tests/rpk_registry_test.py109 # Create the user which rpk will use to authenticate.
MEDIUMtests/rptest/tests/audit_log_test.py2839 # Create a role in Redpanda with the Keycloak group as a member
MEDIUMtests/rptest/tests/audit_log_test.py3795 # Create a schema in a custom context (materializes the context)
MEDIUMtests/rptest/tests/topic_id_migrator_test.py52 # Create the topics to be migrated
MEDIUMtests/rptest/tests/redpanda_oauth_test.py929 # Create a group mapper that includes group membership in the access token.
MEDIUMtests/rptest/tests/redpanda_oauth_test.py933 # Create the group and add the service account to it
MEDIUMtests/rptest/tests/redpanda_oauth_test.py937 # Create a topic and grant access to it via the group ACL principal.
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1159 # Create the group and add the service account to it
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1163 # Create a topic
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1166 # Create a role and add the group as a member using the v2 Admin API
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1241 # Create the group and add the service account to it
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1245 # Create a topic
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1248 # Create a role with the group as a member
MEDIUMtests/rptest/tests/redpanda_oauth_test.py950 # Create a Kafka client that authenticates using OIDC
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1198 # Create a Kafka client that authenticates using OIDC
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1294 # Create a Kafka client that authenticates using OIDC
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1340 # Create a topic
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1343 # Create a role with both groups as members
MEDIUMtests/rptest/tests/redpanda_oauth_test.py1427 # Create the group and add the service user to it
MEDIUMtests/rptest/tests/cluster_recovery_test.py234 # Create a Group ACL on the cluster resource
MEDIUMtests/rptest/tests/cluster_recovery_test.py242 # Create a Group ACL on a topic resource
MEDIUMtests/rptest/tests/cluster_recovery_test.py334 # Create a user with ACL
MEDIUMtests/rptest/tests/cluster_recovery_test.py340 # Create a role with ACL
MEDIUMtests/rptest/tests/cluster_recovery_test.py352 # Create a group ACL
MEDIUMtests/rptest/tests/cluster_recovery_test.py452 # Create a role with only Group members
MEDIUMtests/rptest/tests/cluster_recovery_test.py466 # Create a role with mixed User and Group members
MEDIUMtests/rptest/tests/rpk_role_test.py80 # Create the role
MEDIUMtests/rptest/tests/storage_mode_test.py705 # Create a cloud topic
MEDIUMtests/rptest/tests/storage_mode_test.py745 # Create a tiered_cloud topic
MEDIUMtests/rptest/tests/pandaproxy_test.py1006 # Create a consumer
MEDIUMtests/rptest/tests/pandaproxy_test.py1093 # Create a consumer
MEDIUMtests/rptest/tests/pandaproxy_test.py1706 # Create a consumer
MEDIUMtests/rptest/tests/pandaproxy_test.py2105 # Create the users
MEDIUMtests/rptest/tests/log_compaction_test.py494 # Create a topic with `compact` policy, and a min.cleanable.dirty.ratio of 1.0.
MEDIUM…s/rptest/tests/partition_force_reconfiguration_test.py763 # Create a mix of rf=1 and 3 topics.
MEDIUM…sts/rptest/tests/cluster_linking_topic_syncing_test.py1681 # Create a cloud topic and a normal topic on the source
MEDIUMtests/rptest/tests/consumer_offsets_batch_cache_test.py41 # Create a consumer that will commit random offsets without consuming
MEDIUMtests/rptest/tests/services_self_test.py879 # Create a unique error message that we can search for
MEDIUMtests/rptest/tests/throughput_limits_snc_test.py26# This file is about throughput limiting that works at shard/node/cluster (SNC)
MEDIUMtests/rptest/tests/schema_registry_test.py3254 # Create a topic with incorrect strategy
MEDIUMtests/rptest/tests/schema_registry_test.py6204 # Create a context by creating and then deleting all schemas
MEDIUMtests/rptest/tests/schema_registry_test.py6439 # Create a subject
MEDIUMtests/rptest/tests/schema_registry_test.py8311 # Create the users
MEDIUMtests/rptest/tests/schema_registry_test.py9240 # Define the ACLs
MEDIUMtests/rptest/tests/topic_recovery_test.py155 """This method is invoked after the recovery and partition validation are
MEDIUMtests/rptest/tests/data_migrations_api_test.py1546 # Create a cloud topic
MEDIUMtests/rptest/tests/upgrade_test.py497 # Create a topic with small local retention
MEDIUMtests/rptest/tests/timequery_test.py134 # Create a topic and produce a run of messages we will query.
MEDIUMtests/rptest/tests/cluster_linking_e2e_test.py3217 # Create a Group ACL on the source cluster
MEDIUMtests/rptest/tests/cluster_linking_e2e_test.py3705 # Create a link pointing to the old source cluster
MEDIUMtests/rptest/tests/shard_placement_test.py247 # Create a cluster that doesn't support node-local core assignment yet
MEDIUMtests/rptest/tests/redpanda_kerberos_test.py136 # Create a topic that's visible to "client" iff acl = True
MEDIUMtests/rptest/tests/redpanda_kerberos_test.py149 # Create a topic visible to anybody
MEDIUMtests/rptest/tests/redpanda_kerberos_test.py457 # Create a topic that's visible to "client" iff acl = True
MEDIUMtests/rptest/tests/openssl_config_test.py104 # Create a client certificate for testing TLS connections
MEDIUMtests/rptest/tests/metrics_reporter_test.py486 # Create a second non-default context
MEDIUMtests/rptest/tests/cloud_topics/partial_restart_test.py154 # Create a cloud topic with rf=3 so every node hosts a
23 more matches not shown…
Deep Nesting273 hits · 246 pts
SeverityFileLineSnippet
LOWtools/redpanda-gdb.py2832
LOWtools/redpanda-gdb.py3416
LOWtools/dev_cluster.py635
LOW…d_reconfiguration/invoke_controller_reconfiguration.py505
LOWtools/antithesis/ducktape_test_package.py173
LOWtools/antithesis/single_binary_test_package.py339
LOWtools/offline_log_viewer/kvstore.py141
LOWtools/offline_log_viewer/kvstore.py275
LOWtools/offline_log_viewer/kvstore.py294
LOWtools/offline_log_viewer/kvstore.py311
LOWtools/offline_log_viewer/kvstore.py364
LOWtools/offline_log_viewer/kvstore.py92
LOWtools/offline_log_viewer/kvstore.py405
LOWtools/offline_log_viewer/viewer.py225
LOWtools/offline_log_viewer/controller.py437
LOWtools/offline_log_viewer/controller.py546
LOWtools/offline_log_viewer/controller.py961
LOWtools/offline_log_viewer/model.py268
LOWtools/offline_log_viewer/model.py309
LOWtools/offline_log_viewer/storage.py60
LOWtools/offline_log_viewer/kafka.py60
LOWtools/offline_log_viewer/consumer_offsets.py194
LOWtools/offline_log_viewer/consumer_offsets.py212
LOWtools/offline_log_viewer/tx_coordinator.py22
LOWtools/consumer_offsets_recovery/main.py35
LOWtools/build-perf/build-timer.py59
LOWtools/type-checking/type-check.py325
LOWtools/type-checking/type-check.py381
LOWtools/type-checking/type-check.py498
LOWtools/type-checking/type-check.py578
LOWtools/type-checking/type-check.py658
LOWtools/metrics-mock/metrics-parser.py128
LOWtools/metrics-mock/metrics-mock.py322
LOWtools/metrics-mock/metrics-mock.py198
LOWtests/rp_cloud_cleanup.py686
LOWtests/rp_cloud_cleanup.py130
LOWtests/rp_cloud_cleanup.py250
LOWtests/rp_cloud_cleanup.py272
LOWtests/rp_cloud_cleanup.py467
LOWtests/rp_cloud_cleanup.py586
LOWtests/rp_cloud_cleanup.py505
LOWtests/rp_cloud_cleanup.py531
LOWtests/rptest/trim_results.py35
LOWtests/rptest/clients/rpk.py266
LOWtests/rptest/clients/rpk.py1035
LOWtests/rptest/clients/rpk.py1042
LOWtests/rptest/clients/rpk.py1101
LOWtests/rptest/clients/ping_pong.py137
LOWtests/rptest/clients/kubectl.py24
LOW…s/rptest/infinite_retention/infinite_retention_test.py477
LOWtests/rptest/remote_scripts/topic_operations.py86
LOWtests/rptest/remote_scripts/stream_verifier_txn.py1389
LOWtests/rptest/remote_scripts/stream_verifier_txn.py454
LOWtests/rptest/remote_scripts/stream_verifier_txn.py648
LOWtests/rptest/remote_scripts/stream_verifier_txn.py819
LOWtests/rptest/remote_scripts/stream_verifier_txn.py969
LOWtests/rptest/remote_scripts/compute_storage.py131
LOWtests/rptest/remote_scripts/compute_storage.py164
LOWtests/rptest/chaos_tests/single_fault_test.py160
LOWtests/rptest/tests/consumer_group_test.py173
213 more matches not shown…
Cross-File Repetition39 hits · 195 pts
SeverityFileLineSnippet
HIGHtests/rptest/tests/rpk_registry_test.py0syntax = "proto3"; message simple { string id = 1; }
HIGH…sts/rptest/tests/cluster_linking_topic_syncing_test.py0syntax = "proto3"; message simple { string id = 1; }
HIGHtests/rptest/tests/schema_registry_test.py0syntax = "proto3"; message simple { string id = 1; }
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the effect is validated to be present or false if it's validated to be not present. return none if not en
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the effect is validated to be present or false if it's validated to be not present. return none if not en
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the effect is validated to be present or false if it's validated to be not present. return none if not en
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the effect is validated to be present or false if it's validated to be not present. return none if not en
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the effect is validated to be present or false if it's validated to be not present. return none if not en
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the validator need to run during this test execution stage
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the validator need to run during this test execution stage
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the validator need to run during this test execution stage
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the validator need to run during this test execution stage
HIGHtests/rptest/tests/tiered_storage_model.py0return true if the validator need to run during this test execution stage
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/tiered_storage_model.py0create set of effect observers to run while the data is produced or consumed
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/pandaproxy_test.py0{ "records": [ {"value": "dmvjdg9yaxplza==", "partition": 0}, {"value": "cgfuzgfwcm94eq==", "partition": 1}, {"value": "
HIGHtests/rptest/tests/flink_basic_test.py0test uses same workload with different modes to produce and consume/process given number of transactions
HIGHtests/rptest/e2e_tests/flink_scale_test.py0test uses same workload with different modes to produce and consume/process given number of transactions
HIGHtests/rptest/e2e_tests/flink_scale_test.py0test uses same workload with different modes to produce and consume/process given number of transactions
HIGHtests/rptest/tests/schema_registry_test.py0{ "type": "object", "properties": { "aaaa": {"type": "number"} }, "additionalproperties": {"type": "boolean"}, "required
HIGHtests/rptest/tests/schema_registry_test.py0{ "type": "object", "properties": { "aaaa": {"type": "number"} }, "additionalproperties": {"type": "boolean"}, "required
HIGHtests/rptest/tests/schema_registry_test.py0{ "type": "object", "properties": { "aaaa": {"type": "number"} }, "additionalproperties": {"type": "boolean"}, "required
HIGHtests/rptest/tests/partition_move_interruption_test.py0cancel partition moving with active consumer / producer
HIGHtests/rptest/tests/partition_move_interruption_test.py0cancel partition moving with active consumer / producer
HIGHtests/rptest/tests/partition_move_interruption_test.py0cancel partition moving with active consumer / producer
HIGHtests/rptest/services/kgo_verifier_services.py0wait for the remote processes http endpoint to come up
HIGHtests/rptest/services/transform_verifier_service.py0wait for the remote processes http endpoint to come up
HIGHtests/rptest/services/kgo_repeater_service.py0wait for the remote processes http endpoint to come up
Hallucination Indicators16 hits · 175 pts
SeverityFileLineSnippet
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py191 shadow_link_req.shadow_link.configurations.topic_metadata_sync_options.auto_create_shadow_topic_filters.extend(
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py311 shadow_link_req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.append(
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py405 shadow_link.configurations.client_options.authentication_configuration.scram_configuration.CopyFrom(
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py518 shadow_link.configurations.client_options.authentication_configuration.plain_configuration.CopyFrom(
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py1018 create_link.shadow_link.configurations.schema_registry_sync_options.shadow_schema_registry_topic.CopyFrom(
CRITICAL…sts/rptest/tests/cluster_linking_topic_syncing_test.py1372 shadow_link.configurations.client_options.authentication_configuration.scram_configuration.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py227 link_request.shadow_link.configurations.topic_metadata_sync_options.interval.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py230 link_request.shadow_link.configurations.consumer_offset_sync_options.interval.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py233 link_request.shadow_link.configurations.security_sync_options.interval.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py1271 bad_link_request.shadow_link.configurations.client_options.tls_settings.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py2410 req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.extend(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py4200 req.shadow_link.configurations.topic_metadata_sync_options.start_at_earliest.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py4204 req.shadow_link.configurations.topic_metadata_sync_options.start_at_latest.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py4219 req.shadow_link.configurations.topic_metadata_sync_options.start_at_timestamp.CopyFrom(
CRITICALtests/rptest/tests/cluster_linking_e2e_test.py4434 req.shadow_link.configurations.topic_metadata_sync_options.start_at_timestamp.CopyFrom(
CRITICALtests/rptest/tests/shadow_linking_rnot_test.py490 req.shadow_link.configurations.topic_metadata_sync_options.synced_shadow_topic_properties.append(
AI Slop Vocabulary30 hits · 63 pts
SeverityFileLineSnippet
LOWtools/bazel-tools/support/bazel-tool-trampoline.sh67# opportunistically refresh the cache; on lock-held (exit 9) just use the
MEDIUMtools/rp_storage_tool/src/bucket_reader.rs62 // use. If this vector is empty, then `segment_objects` may be treated as a robust
LOWtests/rptest/remote_scripts/stream_verifier_txn.py425 # For produce only mode just set them to the same value
LOWtests/rptest/remote_scripts/compute_storage.py143 # truncated segment and hence we can just use filesize otherwise
MEDIUMtests/rptest/tests/nodes_decommissioning_test.py202 # use admin API to leverage the retry policy when controller returns 503
MEDIUMtests/rptest/tests/scaling_up_test.py458 # shadow indexing is required when we want to leverage fast partition movements
MEDIUMtests/rptest/tests/scaling_up_test.py569 # shadow indexing is required when we want to leverage fast partition movements
MEDIUMtests/rptest/tests/schema_registry_test.py9302 """Test comprehensive ACL validation including control characters, invalid input values and invalid value combin
MEDIUMtests/rptest/tests/data_migrations_api_test.py573 time.sleep(2) # make sure test harness can see Redpanda is live
MEDIUMtests/rptest/tests/datalake/cluster_restore_test.py470 # To make this test more robust, on top of lowering the upload
MEDIUMtests/rptest/tests/datalake/cluster_restore_test.py586 # To make this test more robust, on top of lowering the upload
LOW…sts/rptest/redpanda_cloud_tests/omb_validation_test.py373 # on an idle T7 cluster. So we just use a SWAG of 100 + 2% of the connection target as the
MEDIUM…rptest/scale_tests/tiered_storage_cache_stress_test.py318 # 2x margin to make the test robust: if this _still_ fails, something is up.
LOWtests/rptest/e2e_tests/workload_manager.py48 # just add it to processing
LOW…rptest/e2e_tests/workloads/flink_transactions_scale.py257 # No config path provided, just use defaults
LOW…/e2e_tests/workloads/flink_table_transactions_basic.py420 # No config path provided, just use defaults
LOW…/e2e_tests/workloads/flink_transactions_topic_swarm.py275 # No config path provided, just use defaults
LOWtests/rptest/e2e_tests/workloads/flink_consume_basic.py154 # No config path provided, just use defaults
LOWtests/rptest/e2e_tests/workloads/flink_produce_basic.py152 # No config path provided, just use defaults
LOWtests/rptest/services/redpanda_cloud.py1032 # duplicate Peering connection, just return existing one.
LOWtests/rptest/services/redpanda_cloud.py1532 # Will just return existing one
MEDIUMtests/rptest/services/tls.py73# the entire configuration file. It may also hold settings pertaining to more
MEDIUMtests/rptest/services/tls.py166# the entire configuration file. It may also hold settings pertaining to more
LOWtests/rptest/services/cluster.py243 # and for any more complicated type, you can just pass a string identifier
LOWtests/rptest/services/kafka.py61 # KafkaService does not have such checks, so we just call the original wait_until_with_progress_check function
MEDIUM.github/workflows/buf.yml39# Job: validate (push, merge_group, and pull_request - comprehensive validation)
MEDIUMsrc/v/cluster/commands.h110 key_t key; // we use key to leverage kafka key based compaction
MEDIUMsrc/v/cluster/commands.h570/// leverage the log compactions (i.e only last command for given key is enough
MEDIUMsrc/v/storage/batch_cache.h482 /// 1. Dirty offsets are monotonic (an assumption we also leverage for
MEDIUMsrc/v/kafka/protocol/schemata/generator.py30# - Build a more robust way to define messages and their contents as
Redundant / Tautological Comments40 hits · 61 pts
SeverityFileLineSnippet
LOW…d_reconfiguration/invoke_controller_reconfiguration.py520 # Check if process is still running
LOWtools/type-checking/type-check.py511 # Check if this section is sorted
LOWtools/type-checking/type-check.py606 # Check if this pattern matches any of the files being moved
LOWtests/local_venv.sh28# Check if venv is up to date
LOWtests/rp_cloud_cleanup.py50 # Check if rpk present
LOWtests/rp_cloud_cleanup.py173 # Check if provider is the same
LOWtests/rp_cloud_cleanup.py495 # Check if network exists in CloudV2
LOWtests/rp_cloud_cleanup.py520 # Check if network exists in CloudV2
LOWtests/rp_cloud_cleanup.py540 # Check if network exists in CloudV2
LOWtests/rptest/clients/kubectl.py546 # Check if such pod exists
LOWtests/rptest/remote_scripts/stream_verifier_txn.py483 # Check if consumed totals had changed
LOWtests/rptest/remote_scripts/stream_verifier_txn.py716 # Check if there is validation needed
LOWtests/rptest/remote_scripts/stream_verifier_txn.py744 # Increment index
LOW…sts/rptest/remote_scripts/cloud/aws_eks_token_cache.sh19# Check if cached token is valid and has >10s remaining
LOWtests/rptest/tests/cluster_features_test.py280 # Set back to v0 for sanity check
LOWtests/rptest/tests/tiered_storage_model.py1522 # Set retention to very small value to trigger size based retention
LOWtests/rptest/tests/log_compaction_test.py387 # Set log_retention_ms to an arbitrarily tiny value and wait for log truncation.
LOWtests/rptest/tests/license_upgrade_test.py201 # Set controller to the upgraded node
LOWtests/rptest/tests/flink_basic_test.py97 # Check if data_type list provides correct number of types
LOW…s/rptest/tests/shadow_indexing_compacted_topic_test.py91 # Set compaction to happen infrequently initially, so we have several log segments.
LOWtests/rptest/tests/timequery_test.py582 # Set timeout to 0 to prevent the cloud storage housekeeping from
LOWtests/rptest/tests/topic_delete_test.py508 # Set retention to 5MB
LOWtests/rptest/scale_tests/large_messages_test.py220 # Set properties to allow for more than just the obligatory read to be returned.
LOWtests/rptest/scale_tests/datalake_scale_test.py200 # Set properties to allow for more than just the obligatory read to be returned.
LOWtests/rptest/e2e_tests/flink_scale_test.py124 # Check if metrics received
LOWtests/rptest/services/redpanda_cloud.py880 # Check if panda-proxy is available
LOWtests/rptest/services/redpanda_cloud.py1000 # Check if cluster is healthy
LOWtests/rptest/services/redpanda_cloud.py1085 # Check if this is a BYOC and delete agent
LOWtests/rptest/services/redpanda_cloud.py1310 # Check if this route is already exists in this table
LOWtests/rptest/services/redpanda_cloud.py1369 # Check if such peering exists
LOWtests/rptest/services/redpanda_cloud.py1458 # Check if such peering exists
LOWtests/rptest/services/redpanda_cloud.py1537 # Check if this is active already
LOWtests/rptest/services/databricks_workspace.py160 # Verify if catalog was created successfully and only then delete.
LOWtests/rptest/services/utils.py224 # Check if this line holds error
LOWtests/rptest/services/cloud_cluster_utils.py82 # Check if succeded
LOWtests/rptest/services/redpanda_installer.py402 # Check if someone else already acquired lock and populated
LOWtests/rptest/services/redpanda.py2437 # Check if stored pod and loaded one is the same
LOWtests/rptest/services/redpanda.py2442 # Check if container inside pod stayed the same
LOWtests/rptest/services/provider_clients/ec2_client.py271 # Check if this is RouteAlreadyExists
LOW.github/workflows/dispatch-docs-updates.yml37 # Check if this is the latest release
Cross-Language Confusion11 hits · 45 pts
SeverityFileLineSnippet
HIGHtests/rptest/tests/tiered_storage_model.py120 self.__solver.push()
HIGHtests/rptest/tests/cloud_storage_inventory_test.py113 f"test -d {self.inventory_dir} && find {self.inventory_dir} -type f || true"
HIGHtests/rptest/tests/schema_registry_test.py1906 These are not supported, but if they're null, we let it pass.
HIGHtests/rptest/tests/sasl_reauth_test.py108 Tests that kafka_sasl_max_reauth_ms{null} produces original behavior
HIGHtests/rptest/tests/datalake/datalake_upgrade_test.py74 - Avro optionals (two-field union of [null, <FIELD>]) (was struct,
HIGHtests/rptest/tuner_integration_tests/net_tuner_test.py281 "umask 077 && rpk redpanda tune net -v", timeout_sec=2
HIGHtests/rptest/services/mitmproxy.py137 cmd = f"sudo cat {LOG_PATH} 2>/dev/null || cat {LOG_PATH}"
HIGHtests/rptest/services/redpanda_installer.py758 relink_cmd = f"unlink /opt/redpanda && ln -s {version_root} /opt/redpanda"
HIGHsrc/transform-sdk/js/package_toolchain.py8 /bin/bash -c 'apt update && apt install -y git && cmake --preset release-static && cmake --build --preset release-stat
HIGHsrc/v/lsm/db/tests/logs_to_trace.py396 let currentShard = null;
HIGHsrc/v/lsm/db/tests/logs_to_trace.py614 if (e.target === container || e.target === timeline || e.target.classList.contains('row-content')) {{
Verbosity Indicators24 hits · 42 pts
SeverityFileLineSnippet
LOWtests/rptest/tests/cluster_features_test.py1250 # Step 1: bootstrap a fresh 2-node cluster reporting v_old.
LOWtests/rptest/tests/cluster_features_test.py1266 # Step 2: add 3 new nodes reporting v_high. Their earliest
LOWtests/rptest/tests/cluster_features_test.py1301 # Step 3: decommission both v_old nodes via a v_high node,
LOWtests/rptest/tests/cluster_features_test.py1322 # Step 4: with both v_old nodes gone, cluster_version must
LOWtests/rptest/tests/cluster_linking_e2e_test.py2187 # Step 4: Create a new Shadow Link on the Shadow Cluster
LOWtests/rptest/tests/cluster_linking_e2e_test.py2191 # Step 5: Wait for the shadow topic to be created on the Shadow Cluster
LOWtests/rptest/tests/cluster_linking_e2e_test.py2199 # Step 6: Verify that the start offset and HWM of all shadow partitions match the source partitions
LOWtests/rptest/tests/cluster_linking_e2e_test.py2130 # Step 2: Write data to the topic across all partitions
LOWtests/rptest/tests/cluster_linking_e2e_test.py2155 # Step 3: Trim the prefix of each partition to its HWM
LOWtests/rptest/tests/list_offsets_epoch_test.py494 # Step 1: seek the throwaway group to start.
LOWtests/rptest/tests/list_offsets_epoch_test.py507 # Step 2: read the committed offset back from the throwaway group.
LOWtests/rptest/tests/list_offsets_epoch_test.py524 # Step 3: write the seek file on the local filesystem (rpk runs
LOWtests/rptest/tests/list_offsets_epoch_test.py530 # Step 4: seek the real group via --to-file (epoch=-1 hardcoded).
LOWtests/rptest/tests/list_offsets_epoch_test.py541 # Step 5: always clean up the throwaway group, even on failure.
LOWsrc/go/rpk/pkg/cli/plugin_cmds.go55 // Step 1: we install the plugin into our existing command space.
LOWsrc/go/rpk/pkg/cli/plugin_cmds.go116 // Step 2: we exec the plugin with --help-autocomplete and we install
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1264 // Step 1: Convert config to proto (config -> proto)
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1268 // Step 2: Convert proto back to config (proto -> config)
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1272 // Step 3: Verify the round-trip config matches the original
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1551 // Step 1: Convert config to cloud ShadowLink proto (simulating what the API returns)
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1566 // Step 2: Convert cloud ShadowLink proto back to config
LOWsrc/go/rpk/pkg/cli/shadow/mapper_test.go1570 // Step 3: Verify the round-trip config matches the original
LOWsrc/v/model/fundamental.h275/// The purpose of this function is to mark every place where we converting
LOWsrc/v/model/fundamental.h634/// The purpose of this function is to mark every place where we converting
Unused Imports25 hits · 24 pts
SeverityFileLineSnippet
LOWtools/offline_log_viewer/consumer_groups.py4
LOWtools/offline_log_viewer/kvstore.py9
LOWtools/offline_log_viewer/controller.py7
LOWtools/offline_log_viewer/consumer_offsets.py5
LOWtests/rptest/clients/admin/google/api/field_info_pb2.py9
LOW…/rptest/clients/admin/google/api/field_behavior_pb2.py9
LOWtests/rptest/clients/admin/google/api/resource_pb2.py9
LOWtests/rptest/remote_scripts/stub_oidc_provider.py1
LOWtests/rptest/remote_scripts/payload_pb2.py14
LOWtests/rptest/tests/gbac_claim_test.py1
LOWtests/rptest/services/kgo_verifier_services.py10
LOWtests/rptest/services/rpk_benchmark_service.py10
LOWtests/rptest/services/stub_oidc_provider.py1
LOWtests/rptest/services/rolling_restarter.py19
LOWtests/rptest/services/redpanda_installer.py28
LOWtests/rptest/services/chaos/faults/all.py13
LOWtests/rptest/services/chaos/faults/all.py13
LOWtests/rptest/services/chaos/faults/all.py13
LOWtests/rptest/services/chaos/faults/all.py14
LOWtests/rptest/services/chaos/faults/all.py15
LOWtests/rptest/services/chaos/workloads/all.py13
LOWtests/rptest/services/chaos/workloads/all.py14
LOWtests/rptest/services/chaos/workloads/all.py15
LOWsrc/v/lsm/db/tests/logs_to_trace.py17
LOWsrc/v/iceberg/tests/avro_decimal_interop_gen.py22
Docstring Block Structure4 hits · 20 pts
SeverityFileLineSnippet
HIGHtests/rptest/clients/kubectl.py243Runs kubectl subcommands on a Cloud Agent with streaming stdout and stderr to output Args:
HIGHtests/rptest/remote_scripts/stream_verifier_txn.py649Consumes all messages from topic Args: logger (logging.Logger): logger class topic (Top
HIGHtests/rptest/services/openmessaging_benchmark.py389 Evaluates the success of a benchmark test based on various metrics and conditions. Parameters:
HIGHtests/rptest/services/openmessaging_benchmark.py449 Detects and evaluates latency spikes in multiple series of latency data based on predefined thresholds.
Example Usage Blocks4 hits · 7 pts
SeverityFileLineSnippet
LOWtools/antithesis/ducktape_test_package.py29# Usage:
LOWtools/antithesis/single_binary_test_package.py22# Usage:
LOW…ols/schema_registry_tools/schemas_command_generator.py3# Usage:
LOWsrc/v/http/tests/http_imposter.h79 /// Example usage:
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippet
MEDIUMbazel/clang_tidy/plugins/redpanda_noop_check.h19 * Included for demonstration purposes and so the tool doesn't complain about
Fake / Example Data2 hits · 2 pts
SeverityFileLineSnippet
LOWsrc/go/rpk/pkg/serde/proto_test.go743 "addressLines": ["123 Main St", "Suite 456"]
LOWsrc/transform-sdk/rust/examples/jaq/README.md16echo '{"data":9,"email":"foo@bar.com"}' | rpk topic produce $MY_INPUT_TOPIC