Apache Iggy: Hyper-Efficient Message Streaming at Laser Speed
This report presents the forensic synthetic code analysis of apache/iggy, a Rust project with 4,586 GitHub stars. SynthScan v2.0 examined 668,855 lines of code across 3226 source files, recording 5209 pattern matches distributed across 16 syntactic categories. The overall adjusted score of 8.5 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 5209 distinct pattern matches across 16 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .asf.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | Cargo.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | codecov.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .pre-commit-config.yaml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | about.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | about.toml | 21 | # LICENSE-binary manifest that is bundled into convenience binary | COMMENT |
| LOW | about.toml | 41 | # BSD-derived. Pulled in by libbz2-rs-sys (runtime). Allowed in | COMMENT |
| LOW | cliff.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | licenserc.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | docker-compose.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .typos.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | rust-toolchain.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .taplo.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .markdownlint.yml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .config/nextest.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | .config/rail.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/Cargo.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/superblock.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/superblock.rs | 21 | //! (`view`, `log_view`, `commit`). The payload is opaque here: this layer | COMMENT |
| LOW | core/journal/src/superblock.rs | 61 | const SUPERBLOCK_VERSION: u16 = 1; | COMMENT |
| LOW | core/journal/src/superblock.rs | 81 | const MAX_RECORD_LEN: usize = HEADER_LEN + MAX_PAYLOAD_LEN + CHECKSUM_LEN; | COMMENT |
| LOW | core/journal/src/superblock.rs | 101 | /// can read the slots with blocking I/O and decode them via [`decode_slots`]. | COMMENT |
| LOW | core/journal/src/superblock.rs | 121 | Unreadable { version: Option<u16> }, | COMMENT |
| LOW | core/journal/src/superblock.rs | 181 | /// Debug tripwire for the single-writer contract (see the `write` impl). | COMMENT |
| LOW | core/journal/src/superblock.rs | 341 | record.extend_from_slice(&ck.to_le_bytes()); | COMMENT |
| LOW | core/journal/src/superblock.rs | 421 | bytes[8], bytes[9], bytes[10], bytes[11], bytes[12], bytes[13], bytes[14], bytes[15], | COMMENT |
| LOW | core/journal/src/superblock.rs | 741 | // `(sequence, slot)` and would tear that slot while both report success. | COMMENT |
| LOW | core/journal/src/lib.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/lib.rs | 41 | COMMENT | |
| LOW | core/journal/src/lib.rs | 61 | fn truncate_from(&self, from_op: u64) -> impl Future<Output = io::Result<usize>>; | COMMENT |
| LOW | core/journal/src/lib.rs | 81 | } | COMMENT |
| LOW | core/journal/src/local_gate.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/local_gate.rs | 21 | //! loop, detached per-client tasks, repair drivers). This gate serializes them | COMMENT |
| LOW | core/journal/src/file_storage.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/file_storage.rs | 61 | /// | COMMENT |
| LOW | core/journal/src/file_storage.rs | 101 | /// two `write_append` calls can interleave at the await; reserving first | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 41 | /// header verbatim, so the zero travels along). Indistinguishable from | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 61 | /// **NOTE:** This number needs to be chosen in balance between number of | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 121 | /// | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 141 | /// and a subsequent step has failed, meaning the on-disk WAL and the | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 201 | /// drop an entry that was durable, acked, and possibly quorum-committed. `pos` alone | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 321 | COMMENT | |
| LOW | core/journal/src/prepare_journal.rs | 361 | /// refuse every future drain and let the journal fill for good. | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 381 | /// | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 541 | // reused as-is; any size change replaces it, since capacity cannot | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 741 | clippy::cast_sign_loss, | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 981 | } | COMMENT |
| LOW | core/journal/src/prepare_journal.rs | 2201 | // In-memory state remains the last-known-good snapshot. Useful | COMMENT |
| LOW | core/message_bus/Cargo.toml | 1 | # Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/replica_tls_mitm.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/ws_client_roundtrip.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/tcp_tls_client_roundtrip.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/replica_tls_roundtrip.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/wss_client_roundtrip.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/vectored_batch.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/quic_client_roundtrip.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/graceful_shutdown.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/replica_auth_handshake.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| LOW | core/message_bus/tests/backpressure.rs | 1 | // Licensed to the Apache Software Foundation (ASF) under one | COMMENT |
| 4383 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 54 | // ── Configuration ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 342 | // ── Sink struct ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 378 | // ── PayloadFormat ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 407 | // ── InfluxDbSink impl ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 707 | // ── Sink trait ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 872 | // ── Tests ───────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 965 | // ── config deserialization ──────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1032 | // ── config ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1069 | // ── to_precision_timestamp ──────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1198 | // ── deny_unknown_fields ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1230 | // ── line-protocol escaping ──────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1322 | // ── append_line ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1432 | // ── V3 append_line parity ───────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1457 | // ── build_body batching logic ───────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1531 | // ── version_label ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1543 | // ── PayloadFormat::from_config sink (warn on unknown) ───────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1568 | // ── append_line: metadata-as-fields when tag flags disabled ────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1656 | // ── append_line: Payload::Json variant ─────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1684 | // ── append_line: timestamp == 0 fallback ────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1714 | // ── build_body: zero-timestamp batch warning ────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1741 | // ── close() ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1755 | // ── get_client error when open() not called ─────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1767 | // ── append_line: text payload via include_metadata fields ───────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1795 | // ── Helper for tests: destructure config variants ───────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1815 | // ── HTTP integration tests ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1830 | // ── test helpers ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1950 | // ── open() ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 1974 | // ── process_batch() ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 2147 | // ── consume() chunking ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 2279 | // ── write URL routing ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/influxdb_sink/src/lib.rs | 2329 | // ── map_precision_v3 ────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/client.rs | 253 | // ── Private helpers ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/client.rs | 280 | // ─── Helper types ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/body.rs | 37 | // ─── Body builders ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/body.rs | 118 | // ─── Tests ─────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/body.rs | 152 | // ── build_json_body ────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/body.rs | 192 | // ── build_string_body ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/body.rs | 283 | // ── build_row_binary_body ──────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/sink.rs | 29 | // ─── open ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/sink.rs | 106 | // ─── consume ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/sink.rs | 178 | // ─── close ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | core/connectors/sinks/clickhouse_sink/src/binary.rs | 81 | // ─── Core recursive serializer ──────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | core/connectors/sinks/clickhouse_sink/src/binary.rs | 89 | // ── Nullable ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM⚡ | core/connectors/sinks/clickhouse_sink/src/binary.rs | 99 | // ── String ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 39 | // ─── Public API ────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 117 | // ── Integers ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 161 | // ── Floats ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 171 | // ── Boolean ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 185 | // ── UUID ───────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 225 | // ── Date types ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 294 | // ── Decimal ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 320 | // ── IP addresses ───────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 338 | // ── Enums ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 356 | // ── Composites ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 439 | // ─── Low-level helpers ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 478 | // ─── Value coercion helpers ─────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 818 | // ─── Tests ─────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 853 | // ── varint ─────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 876 | // ── primitives ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | core/connectors/sinks/clickhouse_sink/src/binary.rs | 1086 | // ── nullable ───────────────────────────────────────────────────────────── | COMMENT |
| 179 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | web/src/lib/domain/MessageDetails.ts | 26 | export function partitionMessagesDetailsMapper(payload: Payload): MessagePartition { | CODE |
| LOW | examples/node/src/multi-tenant/consumer.ts | 67 | async function consumeMessagesFromTenants( | CODE |
| LOW | examples/node/src/multi-tenant/producer.ts | 93 | async function produceMessagesForTenants( | CODE |
| LOW | bdd/python/tests/test_basic_messaging.py | 89 | def stream_created_successfully(context): | CODE |
| LOW | bdd/python/tests/test_basic_messaging.py | 137 | def topic_created_successfully(context): | CODE |
| LOW | bdd/python/tests/test_basic_messaging.py | 205 | def messages_sent_successfully(context): | CODE |
| LOW | bdd/python/tests/test_basic_messaging.py | 247 | def verify_sequential_offsets(context, start_offset, end_offset): | CODE |
| LOW | bdd/python/tests/test_basic_messaging.py | 271 | def verify_last_message_match(context): | CODE |
| LOW⚡ | bdd/python/tests/test_raw_command.py | 67 | def raw_command_succeeds_with_empty_response(context): | CODE |
| LOW⚡ | bdd/python/tests/test_raw_command.py | 73 | def raw_command_succeeds_with_non_empty_response(context): | CODE |
| LOW⚡ | bdd/python/tests/test_raw_command.py | 79 | def raw_command_fails_with_invalid_command(context): | CODE |
| LOW | bdd/php/tests/BasicMessagingFeatureTest.php | 44 | public function testBasicMessagingScenario(string $scenarioName, array $steps): void | CODE |
| LOW | foreign/python/tests/conftest.py | 128 | def pytest_collection_modifyitems(items): | CODE |
| LOW⚡ | foreign/python/tests/test_user.py | 241 | async def test_get_user_rejects_empty_identifier_locally( | CODE |
| LOW⚡ | foreign/python/tests/test_user.py | 250 | async def test_get_user_rejects_out_of_range_numeric_id( | CODE |
| LOW⚡ | foreign/python/tests/test_user.py | 258 | async def test_get_user_returns_same_result_when_called_repeatedly( | CODE |
| LOW | foreign/python/tests/test_user.py | 70 | async def test_create_user_defaults_to_active_status( | CODE |
| LOW | foreign/python/tests/test_user.py | 82 | async def test_create_inactive_user(self, iggy_client: IggyClient, unique_name): | CODE |
| LOW | foreign/python/tests/test_user.py | 96 | async def test_duplicate_username_fails(self, iggy_client: IggyClient, unique_name): | CODE |
| LOW | foreign/python/tests/test_user.py | 108 | async def test_created_user_can_login(self, iggy_client: IggyClient, unique_name): | CODE |
| LOW | foreign/python/tests/test_user.py | 122 | async def test_inactive_user_cannot_login( | CODE |
| LOW | foreign/python/tests/test_user.py | 138 | async def test_deleted_user_cannot_login( | CODE |
| LOW | foreign/python/tests/test_user.py | 158 | async def test_create_user_rejects_out_of_bounds_username( | CODE |
| LOW | foreign/python/tests/test_user.py | 173 | async def test_create_user_rejects_out_of_bounds_password( | CODE |
| LOW | foreign/python/tests/test_user.py | 188 | async def test_create_user_accepts_multibyte_credentials( | CODE |
| LOW | foreign/python/tests/test_user.py | 223 | async def test_get_nonexistent_user_returns_none( | CODE |
| LOW | foreign/python/tests/test_user.py | 280 | async def test_get_users_lists_root_and_created_users( | CODE |
| LOW | foreign/python/tests/test_user.py | 345 | async def test_update_username_and_status_together( | CODE |
| LOW | foreign/python/tests/test_user.py | 365 | async def test_update_user_with_no_fields_is_a_noop( | CODE |
| LOW | foreign/python/tests/test_user.py | 382 | async def test_update_user_applied_repeatedly_is_idempotent( | CODE |
| LOW | foreign/python/tests/test_user.py | 400 | async def test_update_username_to_existing_username_fails( | CODE |
| LOW | foreign/python/tests/test_user.py | 421 | async def test_update_nonexistent_user_fails( | CODE |
| LOW | foreign/python/tests/test_user.py | 437 | async def test_update_user_rejects_out_of_bounds_username( | CODE |
| LOW | foreign/python/tests/test_user.py | 455 | async def test_update_user_accepts_multibyte_username( | CODE |
| LOW | foreign/python/tests/test_user.py | 486 | async def test_delete_user_by_numeric_id( | CODE |
| LOW | foreign/python/tests/test_user.py | 498 | async def test_delete_nonexistent_user_fails( | CODE |
| LOW | foreign/python/tests/test_user.py | 507 | async def test_delete_root_user_fails( | CODE |
| LOW | foreign/python/tests/test_user.py | 519 | async def test_delete_user_twice_fails(self, iggy_client: IggyClient, unique_name): | CODE |
| LOW | foreign/python/tests/test_user.py | 530 | async def test_delete_inactive_user(self, iggy_client: IggyClient, unique_name): | CODE |
| LOW | foreign/python/tests/test_user.py | 540 | async def test_deleted_user_disappears_from_listings( | CODE |
| LOW | foreign/python/tests/test_user.py | 556 | async def test_deleted_user_live_session_loses_identity( | CODE |
| LOW | foreign/python/tests/test_user.py | 583 | async def test_deleted_username_is_reusable_with_fresh_credentials( | CODE |
| LOW | foreign/python/tests/test_user.py | 620 | async def test_user_management_requires_connection_and_auth(method_name, unique_name): | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 37 | async def _create_consumer_group_with_numeric_ids( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 71 | async def test_create_and_get_consumer_group( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 103 | async def test_create_consumer_group_accepts_numeric_stream_and_topic_ids( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 145 | async def test_duplicate_consumer_group_creation_fails( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 173 | async def test_create_consumer_group_requires_connection_and_auth( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 201 | async def test_get_consumer_group_by_name_and_id( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 245 | async def test_get_nonexistent_consumer_group( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 274 | async def test_get_consumer_group_returns_members( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 315 | async def test_get_consumer_group_requires_connection_and_auth(self, unique_name): | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 341 | async def test_get_consumer_groups_in_empty_topic_returns_empty_list( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 359 | async def test_get_consumer_groups_lists_topic_groups( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 393 | async def test_get_consumer_groups_accepts_numeric_stream_and_topic_ids( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 426 | async def test_get_consumer_groups_returns_same_result_when_called_repeatedly( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 455 | async def test_get_consumer_groups_requires_connection_and_auth(self, unique_name): | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 473 | async def test_delete_consumer_group_removes_only_target_group( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 521 | async def test_delete_consumer_group_accepts_numeric_ids( | CODE |
| LOW | foreign/python/tests/test_consumer_group.py | 540 | async def test_delete_nonexistent_consumer_group_fails( | CODE |
| 255 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 631 | // Step 3: Wait for WireMock to receive all requests | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 638 | // Step 4: Verify bare payload — no metadata wrapper | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 700 | // Step 3: Wait for all 5 requests | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 707 | // Step 4: Extract offsets from metadata | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 763 | // Step 1: Both topics created by connector_multi_topic_stream seed (runs before | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 767 | // Step 2: Send 2 messages to topic 1 with source identifier in payload | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 813 | // Step 4: Wait for all 3 messages (2 from topic 1 + 1 from topic 2) | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 820 | // Step 5: Group by iggy_topic metadata and verify counts + payload content | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 211 | // Step 1: Build 3 JSON messages with distinct payloads | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 231 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 242 | // Step 3: Wait for WireMock to receive all 3 individual HTTP requests | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 257 | // Step 4: Verify each request has correct method, URL, and envelope structure | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 290 | // Step 5: Verify content type header | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 353 | // Step 1: Wait for the single NDJSON request. The seed pre-published all | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 365 | // Step 2: Parse NDJSON body — each line is a separate JSON envelope | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 387 | // Step 3: Verify NDJSON content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 450 | // Step 1: Wait for the single JSON array request. The seed pre-published all | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 462 | // Step 2: Parse body as JSON array and verify structure | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 485 | // Step 3: Verify JSON content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 513 | // Step 1: Build 3 raw byte messages | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 532 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 543 | // Step 3: Wait for all 3 raw HTTP requests (raw mode is always 1:1) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 557 | // Step 4: Verify raw mode — no metadata envelope | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 572 | // Step 5: Verify raw content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 600 | // Step 1: Build 3 simple JSON messages | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 620 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 676 | // Step 1: Build 5 messages (more than default 3 to better test ordering) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 689 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 725 | // Step 5: Sort and verify contiguous offsets (delivery order may vary) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 793 | // Step 3: Send 1 message to topic 2 with different source identifier | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 856 | // Step 6: Verify exact message counts per topic | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 68 | // Step 1: Produce messages to exactly the same stream/topic/partition | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 71 | // Step 2: Create a consumer group with singular consumer that uses auto_commit | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 74 | // Step 3: Consume 50% of the produced messages | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 81 | // Step 4: Disconnect the consumer | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 84 | // Step 5: Check if the committed offset is at the place where it should be (halfway through) | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 91 | // Step 6: Reconnect the consumer | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 94 | // Step 7: Consume rest of the messages | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 101 | // Step 8: Check if the committed offset is at the end | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 63 | // Step 1: Produce 100 messages | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 70 | // Step 2: Create consumer group and consume messages | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 113 | // Step 3: Delete the consumer group | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 123 | // Step 4: Try to get offset for the deleted consumer group - should not exist | COMMENT |
| LOW | …tests/server/scenarios/restart_offset_skip_scenario.rs | 108 | // Step 3: Restart server | COMMENT |
| LOW | core/metadata/src/stm/consumer_group.rs | 202 | // Step 1: hand unassigned partitions straight to idle members. | COMMENT |
| LOW | core/metadata/src/stm/consumer_group.rs | 225 | // Step 2: mark excess on over-assigned members as pending revocation. | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 265 | # Step 1: Publish iggy_binary_protocol (depends on nothing in-tree) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 306 | # Step 2: Publish iggy_common (depends on iggy_binary_protocol) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 347 | # Step 3: Publish iggy SDK (depends on common and protocol) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 388 | # Step 4: Publish iggy-cli (depends on SDK and protocol) | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 34 | # Step 1: Build JARs | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 41 | # Step 2: Start Docker environment | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 47 | # Step 3: Wait for services to be healthy | COMMENT |
| LOW | …al-processors/iggy-connector-pinot/integration-test.sh | 92 | # Step 4: Login to Iggy and create stream/topic | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 134 | # Step 5: Create Pinot schema | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 141 | # Step 6: Create Pinot table | COMMENT |
| LOW | …al-processors/iggy-connector-pinot/integration-test.sh | 159 | # Step 7: Send test messages to Iggy | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 187 | # Step 8: Wait for ingestion | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 191 | # Step 9: Query Pinot and verify data | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 631 | // Step 3: Wait for WireMock to receive all requests | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 638 | // Step 4: Verify bare payload — no metadata wrapper | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 700 | // Step 3: Wait for all 5 requests | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 707 | // Step 4: Extract offsets from metadata | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 763 | // Step 1: Both topics created by connector_multi_topic_stream seed (runs before | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 767 | // Step 2: Send 2 messages to topic 1 with source identifier in payload | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 813 | // Step 4: Wait for all 3 messages (2 from topic 1 + 1 from topic 2) | COMMENT |
| LOW⚡ | core/integration/tests/connectors/http/http_sink.rs | 820 | // Step 5: Group by iggy_topic metadata and verify counts + payload content | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 211 | // Step 1: Build 3 JSON messages with distinct payloads | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 231 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 242 | // Step 3: Wait for WireMock to receive all 3 individual HTTP requests | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 257 | // Step 4: Verify each request has correct method, URL, and envelope structure | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 290 | // Step 5: Verify content type header | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 353 | // Step 1: Wait for the single NDJSON request. The seed pre-published all | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 365 | // Step 2: Parse NDJSON body — each line is a separate JSON envelope | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 387 | // Step 3: Verify NDJSON content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 450 | // Step 1: Wait for the single JSON array request. The seed pre-published all | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 462 | // Step 2: Parse body as JSON array and verify structure | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 485 | // Step 3: Verify JSON content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 513 | // Step 1: Build 3 raw byte messages | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 532 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 543 | // Step 3: Wait for all 3 raw HTTP requests (raw mode is always 1:1) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 557 | // Step 4: Verify raw mode — no metadata envelope | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 572 | // Step 5: Verify raw content type | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 600 | // Step 1: Build 3 simple JSON messages | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 620 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 676 | // Step 1: Build 5 messages (more than default 3 to better test ordering) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 689 | // Step 2: Publish messages to Iggy | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 725 | // Step 5: Sort and verify contiguous offsets (delivery order may vary) | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 793 | // Step 3: Send 1 message to topic 2 with different source identifier | COMMENT |
| LOW | core/integration/tests/connectors/http/http_sink.rs | 856 | // Step 6: Verify exact message counts per topic | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 68 | // Step 1: Produce messages to exactly the same stream/topic/partition | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 71 | // Step 2: Create a consumer group with singular consumer that uses auto_commit | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 74 | // Step 3: Consume 50% of the produced messages | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 81 | // Step 4: Disconnect the consumer | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 84 | // Step 5: Check if the committed offset is at the place where it should be (halfway through) | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 91 | // Step 6: Reconnect the consumer | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 94 | // Step 7: Consume rest of the messages | COMMENT |
| LOW⚡ | …os/consumer_group_auto_commit_reconnection_scenario.rs | 101 | // Step 8: Check if the committed offset is at the end | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 63 | // Step 1: Produce 100 messages | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 70 | // Step 2: Create consumer group and consume messages | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 113 | // Step 3: Delete the consumer group | COMMENT |
| LOW⚡ | …er/scenarios/consumer_group_offset_cleanup_scenario.rs | 123 | // Step 4: Try to get offset for the deleted consumer group - should not exist | COMMENT |
| LOW | …tests/server/scenarios/restart_offset_skip_scenario.rs | 108 | // Step 3: Restart server | COMMENT |
| LOW | core/metadata/src/stm/consumer_group.rs | 202 | // Step 1: hand unassigned partitions straight to idle members. | COMMENT |
| LOW | core/metadata/src/stm/consumer_group.rs | 225 | // Step 2: mark excess on over-assigned members as pending revocation. | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 265 | # Step 1: Publish iggy_binary_protocol (depends on nothing in-tree) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 306 | # Step 2: Publish iggy_common (depends on iggy_binary_protocol) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 347 | # Step 3: Publish iggy SDK (depends on common and protocol) | COMMENT |
| LOW | .github/workflows/_publish_rust_crates.yml | 388 | # Step 4: Publish iggy-cli (depends on SDK and protocol) | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 34 | # Step 1: Build JARs | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 41 | # Step 2: Start Docker environment | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 47 | # Step 3: Wait for services to be healthy | COMMENT |
| LOW | …al-processors/iggy-connector-pinot/integration-test.sh | 92 | # Step 4: Login to Iggy and create stream/topic | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 134 | # Step 5: Create Pinot schema | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 141 | # Step 6: Create Pinot table | COMMENT |
| LOW | …al-processors/iggy-connector-pinot/integration-test.sh | 159 | # Step 7: Send test messages to Iggy | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 187 | # Step 8: Wait for ingestion | COMMENT |
| LOW⚡ | …al-processors/iggy-connector-pinot/integration-test.sh | 191 | # Step 9: Query Pinot and verify data | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …apache/iggy/client/blocking/tcp/TlsConnectionTest.java | 145 | org.apache.iggy.consumergroup.Consumer.of(0L), | CODE |
| CRITICAL | …che/iggy/client/async/AsyncConnectionPoolAuthTest.java | 175 | org.apache.iggy.identifier.TopicId.of("test-topic"), | CODE |
| CRITICAL | …che/iggy/client/async/AsyncConnectionPoolAuthTest.java | 212 | org.apache.iggy.identifier.TopicId.of("test-topic"), | CODE |
| CRITICAL | …che/iggy/client/async/AsyncConnectionPoolAuthTest.java | 230 | org.apache.iggy.identifier.TopicId.of("test-topic"), | CODE |
| CRITICAL | …/java/org/apache/iggy/serde/BytesDeserializerTest.java | 684 | .isCloseTo(0.91f, org.assertj.core.data.Offset.offset(0.01f)); | CODE |
| CRITICAL | …n/java/org/apache/iggy/flink/example/WordCountJob.java | 109 | .returns(org.apache.flink.api.common.typeinfo.Types.TUPLE( | CODE |
| CRITICAL | …org/apache/iggy/connector/flink/source/IggySource.java | 185 | return Consumer.group(org.apache.iggy.identifier.ConsumerId.of(consumerGroupName)); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | README.md | 336 | Send another message 'lorem ipsum' (message ID 2) to the same stream, topic and partition: | CODE |
| LOW | README.md | 338 | `cargo run --bin iggy -- -u <iggy_username> -p <iggy_password> message send --partition-id 1 dev sample "lorem ipsum"` | CODE |
| LOW | core/connectors/sinks/influxdb_sink/src/lib.rs | 2180 | ..v2_config("placeholder").into_v2().unwrap() | CODE |
| LOW | core/connectors/sdk/tests/protobuf_integration.rs | 116 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/tests/protobuf_integration.rs | 122 | "street": "123 Main St", | CODE |
| LOW | core/connectors/sdk/tests/flatbuffer_integration.rs | 108 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/tests/flatbuffer_integration.rs | 114 | "street": "123 Main St", | CODE |
| LOW | core/connectors/sdk/tests/flatbuffer_integration.rs | 254 | "email": "test@test.com", | CODE |
| LOW | core/connectors/sdk/src/transforms/proto_convert.rs | 812 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/src/transforms/proto_convert.rs | 823 | assert!(proto_text.contains("John Doe")); | CODE |
| LOW | core/connectors/sdk/src/transforms/proto_convert.rs | 850 | "full_name": "John Doe", | CODE |
| LOW | core/connectors/sdk/src/encoders/proto.rs | 739 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/src/encoders/proto.rs | 844 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/src/encoders/proto.rs | 1085 | "name": "John Doe", | CODE |
| LOW | core/connectors/sdk/src/encoders/proto.rs | 1109 | assert!(data_str.contains("John Doe"), "Should contain user name"); | CODE |
| LOW | core/connectors/sources/postgres_source/README.md | 90 | "name": "John Doe", | CODE |
| LOW | …tests/connectors/influxdb/source_v3_config/config.toml | 40 | token = "placeholder" | CODE |
| LOW | …n/tests/connectors/influxdb/sink_v3_config/config.toml | 42 | token = "placeholder" | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2843 | let dummy_id = Identifier::numeric(0).unwrap(); | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2847 | IggyError::StreamIdNotFound(dummy_id.clone()).as_code(), | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2849 | IggyError::TopicIdNotFound(dummy_id.clone(), dummy_id.clone()).as_code(), | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2899 | let dummy_id = Identifier::numeric(0).unwrap(); | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2902 | IggyError::StreamIdNotFound(dummy_id.clone()).as_code(), | CODE |
| LOW⚡ | …gration/tests/server/scenarios/permissions_scenario.rs | 2904 | IggyError::TopicIdNotFound(dummy_id.clone(), dummy_id.clone()).as_code(), | CODE |
| LOW | …sts/cli/message/test_message_send_from_file_command.rs | 263 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …sts/cli/message/test_message_send_from_file_command.rs | 263 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …tests/cli/message/test_message_poll_to_file_command.rs | 230 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …tests/cli/message/test_message_poll_to_file_command.rs | 230 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …ation/tests/cli/message/test_message_reply_via_file.rs | 32 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …ation/tests/cli/message/test_message_reply_via_file.rs | 32 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit", | CODE |
| LOW | …gration/tests/cli/message/test_message_poll_command.rs | 259 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit".into(), | CODE |
| LOW | …gration/tests/cli/message/test_message_poll_command.rs | 259 | "Lorem ipsum dolor sit amet, consectetur adipiscing elit".into(), | CODE |
| LOW | …apache/iggy/client/blocking/http/ObjectMapperTest.java | 363 | Message message = Message.of("placeholder"); | STRING |
| LOW | …apache/iggy/client/blocking/http/ObjectMapperTest.java | 397 | Message originalMessage = Message.of("placeholder"); | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/extract-version.sh | 346 | # Check if component exists | COMMENT |
| LOW | scripts/run-benches.sh | 48 | # Display results | COMMENT |
| LOW⚡ | scripts/profile.sh | 33 | # Check if the script is being run with the correct arguments | COMMENT |
| LOW⚡ | scripts/profile.sh | 39 | # Check if the app name and profiling mode are valid | COMMENT |
| LOW⚡ | scripts/profile.sh | 45 | # Check if the profiling mode is valid | COMMENT |
| LOW | scripts/profile.sh | 73 | # Check if the system settings for perf are configured correctly | COMMENT |
| LOW | scripts/profile.sh | 204 | # Display results | COMMENT |
| LOW | scripts/ci/shellcheck.sh | 81 | # Check if shellcheck is installed | COMMENT |
| LOW | scripts/ci/license-headers.sh | 56 | # Check if ASF_LICENSE.txt exists | COMMENT |
| LOW | scripts/ci/license-headers.sh | 75 | # Check if HawkEye is available | COMMENT |
| LOW | scripts/ci/taplo.sh | 70 | # Check if taplo is installed | COMMENT |
| LOW | scripts/ci/markdownlint.sh | 69 | # Check if markdownlint is installed | COMMENT |
| LOW | scripts/ci/trailing-newline.sh | 133 | # Check if file ends with a newline | COMMENT |
| LOW | scripts/dashboard/run_dev.sh | 30 | # Check if trunk is installed | COMMENT |
| LOW | scripts/performance/run-standard-performance-suite.sh | 211 | # Check if the server is running | COMMENT |
| LOW | scripts/performance/run-standard-performance-suite.sh | 265 | # Check if the server is running | COMMENT |
| LOW | .github/workflows/publish.yml | 473 | # Check if tag exists on the remote. Querying the REMOTE (not | COMMENT |
| LOW | .github/actions/go/post-merge/action.yml | 37 | # Check if version matches semantic versioning | COMMENT |
| LOW | .github/actions/python-maturin/post-merge/action.yml | 45 | # Check if version matches Python/PEP 440 versioning | COMMENT |
| LOW | .github/actions/python-maturin/post-merge/action.yml | 83 | # Check if directory exists and has files | COMMENT |
| LOW | .github/actions/node-npm/post-merge/action.yml | 131 | # Check if files to be published exist | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | core/connectors/sinks/elasticsearch_sink/src/lib.rs | 96 | // primary #3728 flake fix (that is the harness readiness gate, which | COMMENT |
| MEDIUM | core/connectors/sinks/doris_sink/src/lib.rs | 781 | /// `#[doc(hidden)]`: `pub` only so the integration test harness can reproduce | COMMENT |
| MEDIUM | …data_integrity/verify_auto_commit_offset_replicates.rs | 152 | /// it is robust to the stream/topic/partition id layout; the test drives exactly | COMMENT |
| MEDIUM | core/integration/src/harness/disk.rs | 339 | /// so it is robust to the stream/topic/partition id layout. Reads the leading | COMMENT |
| MEDIUM | core/harness_derive/src/lib.rs | 20 | //! The `#[iggy_harness]` attribute replaces boilerplate harness setup with a declarative DSL. | COMMENT |
| MEDIUM | core/harness_derive/src/codegen.rs | 618 | let #var_name = <#ty as ::integration::harness::TestFixture>::setup() | CODE |
| MEDIUM | bdd/rust/Cargo.toml | 35 | # `test` is set to false because cucumber uses its own test harness, which | COMMENT |
| MEDIUM | foreign/python/src/client.rs | 91 | /// Future versions might utilize asyncio for more Pythonic async. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | foreign/python/tests/test_message_operations.py | 193 | assert isinstance(msg.length(), int) and msg.length() > 0 | CODE |
| HIGH | foreign/python/tests/test_message_operations.py | 641 | assert message.length() == len(expected_payload) | CODE |
| HIGH | foreign/python/tests/test_message_operations.py | 682 | assert message.length() == len(expected_payload) | CODE |
| HIGH | foreign/python/tests/test_message_operations.py | 722 | assert message.length() == len(payload) | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | core/message_bus/src/installer/replica.rs | 44 | /// Shared scaffold for both delegated install directions: shutdown | COMMENT |
| MEDIUM | core/message_bus/src/installer/replica.rs | 314 | /// `spawn_replica_install` scaffold; transports with no equivalent | COMMENT |
| MEDIUM | core/message_bus/src/installer/tcp.rs | 43 | /// scaffold (`super::replica::install_replica_inbound` / `_outbound`). | COMMENT |
| MEDIUM | bdd/go/tests/leader_redirection.go | 407 | // metadata checks skipped in scaffold | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | examples/python/basic/producer.py | 117 | except Exception as error: | CODE |
| LOW | examples/python/basic/consumer.py | 93 | except Exception as error: | CODE |
| LOW | examples/python/getting-started/producer.py | 191 | except Exception as error: | CODE |
| LOW | examples/python/getting-started/consumer.py | 135 | except Exception as error: | CODE |
| LOW | examples/python/getting-started/consumer.py | 171 | except Exception as error: | CODE |
| LOW | examples/python/message-headers/common.py | 170 | except Exception as error: | CODE |
| LOW | examples/python/message-headers/common.py | 215 | except Exception as error: | CODE |
| LOW | foreign/python/tests/utils.py | 109 | except Exception as err: | CODE |
| LOW | foreign/python/scripts/test.sh | 58 | except Exception as e: | CODE |
| MEDIUM | foreign/python/scripts/test.sh | 50 | def test_connection(): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | core/connectors/sinks/http_sink/config.toml | 89 | Authorization = "Bearer <YOUR_TOKEN_HERE>" | CODE |
| HIGH | core/connectors/runtime/README.md | 141 | api-key = "your-api-key" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | scripts/extract-version.sh | 25 | # Usage: | COMMENT |
| LOW | scripts/verify-crates-publish.sh | 30 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | scripts/performance/run-standard-performance-suite.sh | 101 | # Create a directory for the performance results | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | core/simulator/src/packet.rs | 647 | // TODO: implement record/replay_recorded for deterministic replay support. | COMMENT |