apache/iggy

9.0

Adjusted Score

9.0

Raw Score

100%

Time Factor

2026-07-14

Last Push

4.4K

Stars

Rust

Language

544.5K

Lines of Code

3.2K

Files

4.3K

Pattern Hits

2026-07-14

Scan Date

0.00

HC Hit Rate

What These Metrics Mean

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

Score History

Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.

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

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 8HIGH 6MEDIUM 238LOW 4058

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 4310 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.

Over-Commented Block3680 hits · 3655 pts

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/lib.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	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	81	///	COMMENT
LOW	core/journal/src/file_storage.rs	101	/// seen under interleaved `on_replicate` calls (a queued op drained while	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	/// snapshots. If the journal wraps past this window, older un-snapshotted	COMMENT
LOW	core/journal/src/prepare_journal.rs	101	/// The in-memory index is a fixed-size slot array indexed by	COMMENT
LOW	core/journal/src/prepare_journal.rs	121	/// in-memory index no longer agree. All IO entry points must	COMMENT
LOW	core/journal/src/prepare_journal.rs	181	),	COMMENT
LOW	core/journal/src/prepare_journal.rs	221	impl Drop for TmpFileGuard {	COMMENT
LOW	core/journal/src/prepare_journal.rs	281	\|\| u64::from(header.size) > MAX_ENTRY_SIZE	COMMENT
LOW	core/journal/src/prepare_journal.rs	561		COMMENT
LOW	core/journal/src/prepare_journal.rs	661	}	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
LOW	core/message_bus/tests/replica_tls_bench.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/replica_tls_bench.rs	21	//!	COMMENT
LOW	core/message_bus/tests/wss_client_listener.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/reconnect.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/reconnect_skip_connected.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/tcp_client_roundtrip.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/cancel_unsafe.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/cancel_unsafe.rs	21	//!	COMMENT
LOW	core/message_bus/tests/cancel_unsafe.rs	41	//!	COMMENT
LOW	core/message_bus/tests/tcp_tls_client_listener.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/directional_connection.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/shard_zero_gating.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/connection_lost_notify.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/replica_roundtrip.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/duplicate_client_id.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/tcp_tls_cancel_safe.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/tcp_tls_cancel_safe.rs	21	//!	COMMENT
LOW	core/message_bus/tests/head_of_line.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	core/message_bus/tests/installer_panic_cleanup.rs	1	// Licensed to the Apache Software Foundation (ASF) under one	COMMENT
3620 more matches not shown…

Decorative Section Separators226 hits · 692 pts

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
166 more matches not shown…

Hyper-Verbose Identifiers175 hits · 142 pts

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	68	async function consumeMessagesFromTenants(	CODE
LOW	examples/node/src/multi-tenant/producer.ts	95	async function produceMessagesForTenants(	CODE
LOW	bdd/python/tests/test_basic_messaging.py	90	def stream_created_successfully(context):	CODE
LOW	bdd/python/tests/test_basic_messaging.py	138	def topic_created_successfully(context):	CODE
LOW	bdd/python/tests/test_basic_messaging.py	206	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/php/tests/BasicMessagingFeatureTest.php	40	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_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
LOW	foreign/python/tests/test_consumer_group.py	562	async def test_delete_consumer_group_removes_live_member(	CODE
LOW	foreign/python/tests/test_consumer_group.py	601	async def test_join_consumer_group_adds_member_once_when_repeated(	CODE
LOW	foreign/python/tests/test_consumer_group.py	634	async def test_join_consumer_group_accepts_numeric_ids(	CODE
LOW	foreign/python/tests/test_consumer_group.py	663	async def test_join_nonexistent_consumer_group_fails(	CODE
LOW	foreign/python/tests/test_consumer_group.py	689	async def test_leave_consumer_group_removes_member(	CODE
LOW	foreign/python/tests/test_consumer_group.py	720	async def test_leave_consumer_group_accepts_numeric_ids(	CODE
LOW	foreign/python/tests/test_consumer_group.py	748	async def test_leave_consumer_group_twice_fails_second_time(	CODE
LOW	foreign/python/tests/test_consumer_group.py	773	async def test_leave_nonexistent_consumer_group_fails(	CODE
LOW	foreign/python/tests/test_consumer_group.py	804	async def test_consumer_group_lifecycle_requires_connection_and_auth(	CODE
LOW	foreign/python/tests/test_consumer_group.py	827	async def test_consumer_group_metadata(self, iggy_client: IggyClient, unique_name):	CODE
LOW	foreign/python/tests/test_consumer_group.py	860	async def test_get_last_consumed_offset_updates_as_messages_are_consumed(	CODE
LOW	foreign/python/tests/test_consumer_group.py	934	async def test_get_last_stored_offset_updates_when_offsets_are_stored(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1012	async def test_delete_offset_behavior(self, iggy_client: IggyClient, unique_name):	CODE
LOW	foreign/python/tests/test_consumer_group.py	1156	async def test_iter_messages_with_first_reads_existing_messages(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1202	async def test_iter_messages_with_last_reads_last_existing_message(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1251	async def test_iter_messages_with_last_and_batch_length_two_reads_last_two_messages(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1295	async def test_consume_messages_with_last_reads_last_existing_message(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1347	async def test_iter_messages_with_offset_starts_at_exact_message(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1416	async def test_consume_messages_with_offset_starts_at_exact_message(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1488	async def test_iter_messages_with_timestamp_starts_at_or_after_timestamp(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1561	async def test_consume_messages_with_timestamp_starts_at_or_after_timestamp(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1637	async def test_iter_messages_updates_last_consumed_offset(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1695	async def test_iter_messages_reads_across_multiple_batches(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1740	async def test_store_offset_respects_allow_replay(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1819	async def test_consumer_group_retries_initialization_until_stream_and_topic_exist(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1858	async def test_consumer_group_can_disable_auto_join(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1892	async def test_consumer_group_can_disable_auto_create_when_group_exists(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1940	async def test_consumer_group_missing_stream_or_topic_fails(	CODE
LOW	foreign/python/tests/test_consumer_group.py	1968	async def test_consumer_group_auto_create_disabled_fails_for_missing_group(	CODE
LOW	foreign/python/tests/test_consumer_group.py	2009	async def test_consumer_group_requires_complete_init_retry_configuration(	CODE
LOW	foreign/python/tests/test_consumer_group.py	2037	async def test_consumer_group_before_connect_fails(self, unique_name):	CODE
LOW	foreign/python/tests/test_consumer_group.py	2055	async def test_consumer_group_before_login_fails(self, unique_name):	CODE
LOW	foreign/python/tests/test_topic.py	52	async def test_create_and_get_topic(	CODE
115 more matches not shown…

Verbosity Indicators67 hits · 100 pts

Severity	File	Line	Snippet	Context
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	618	// Step 3: Wait for WireMock to receive all requests	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	625	// Step 4: Verify bare payload — no metadata wrapper	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	687	// Step 3: Wait for all 5 requests	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	694	// Step 4: Extract offsets from metadata	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	750	// Step 1: Both topics created by connector_multi_topic_stream seed (runs before	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	754	// Step 2: Send 2 messages to topic 1 with source identifier in payload	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	800	// 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	807	// Step 5: Group by iggy_topic metadata and verify counts + payload content	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	208	// Step 1: Build 3 JSON messages with distinct payloads	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	228	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	239	// Step 3: Wait for WireMock to receive all 3 individual HTTP requests	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	254	// Step 4: Verify each request has correct method, URL, and envelope structure	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	287	// Step 5: Verify content type header	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	315	// Step 1: Build 3 JSON event messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	335	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	346	// Step 3: Wait for single NDJSON request (all messages batched into one)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	357	// Step 4: Parse NDJSON body — each line is a separate JSON envelope	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	379	// Step 5: Verify NDJSON content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	407	// Step 1: Build 3 JSON messages representing different event types	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	427	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	438	// Step 3: Wait for single JSON array request (all messages in one body)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	449	// Step 4: Parse body as JSON array and verify structure	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	472	// Step 5: Verify JSON content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	500	// Step 1: Build 3 raw byte messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	519	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	530	// 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	544	// Step 4: Verify raw mode — no metadata envelope	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	559	// Step 5: Verify raw content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	587	// Step 1: Build 3 simple JSON messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	607	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	663	// Step 1: Build 5 messages (more than default 3 to better test ordering)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	676	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	712	// Step 5: Sort and verify contiguous offsets (delivery order may vary)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	780	// Step 3: Send 1 message to topic 2 with different source identifier	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	843	// 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	112	// Step 3: Restart server	COMMENT
LOW	core/server/src/metadata/consumer_group.rs	86	// Step 1: Assign unassigned partitions to idle members	COMMENT
LOW	core/server/src/metadata/consumer_group.rs	112	// Step 2: Mark excess partitions as pending revocation	COMMENT
LOW	core/server/src/metadata/reader.rs	268	// Step 1: Resolve group ID	COMMENT
LOW	core/server/src/metadata/reader.rs	318	// Step 2: Find member by client_id (same read guard, same metadata snapshot)	COMMENT
LOW	core/metadata/src/stm/consumer_group.rs	199	// Step 1: hand unassigned partitions straight to idle members.	COMMENT
LOW	core/metadata/src/stm/consumer_group.rs	222	// Step 2: mark excess on over-assigned members as pending revocation.	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	260	# Step 1: Publish iggy_binary_protocol (depends on nothing in-tree)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	289	# Step 2: Publish iggy_common (depends on iggy_binary_protocol)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	318	# Step 3: Publish iggy SDK (depends on common and protocol)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	347	# 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
7 more matches not shown…

Structural Annotation Overuse67 hits · 100 pts

Severity	File	Line	Snippet	Context
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	618	// Step 3: Wait for WireMock to receive all requests	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	625	// Step 4: Verify bare payload — no metadata wrapper	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	687	// Step 3: Wait for all 5 requests	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	694	// Step 4: Extract offsets from metadata	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	750	// Step 1: Both topics created by connector_multi_topic_stream seed (runs before	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	754	// Step 2: Send 2 messages to topic 1 with source identifier in payload	COMMENT
LOW⚡	core/integration/tests/connectors/http/http_sink.rs	800	// 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	807	// Step 5: Group by iggy_topic metadata and verify counts + payload content	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	208	// Step 1: Build 3 JSON messages with distinct payloads	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	228	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	239	// Step 3: Wait for WireMock to receive all 3 individual HTTP requests	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	254	// Step 4: Verify each request has correct method, URL, and envelope structure	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	287	// Step 5: Verify content type header	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	315	// Step 1: Build 3 JSON event messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	335	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	346	// Step 3: Wait for single NDJSON request (all messages batched into one)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	357	// Step 4: Parse NDJSON body — each line is a separate JSON envelope	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	379	// Step 5: Verify NDJSON content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	407	// Step 1: Build 3 JSON messages representing different event types	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	427	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	438	// Step 3: Wait for single JSON array request (all messages in one body)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	449	// Step 4: Parse body as JSON array and verify structure	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	472	// Step 5: Verify JSON content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	500	// Step 1: Build 3 raw byte messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	519	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	530	// 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	544	// Step 4: Verify raw mode — no metadata envelope	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	559	// Step 5: Verify raw content type	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	587	// Step 1: Build 3 simple JSON messages	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	607	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	663	// Step 1: Build 5 messages (more than default 3 to better test ordering)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	676	// Step 2: Publish messages to Iggy	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	712	// Step 5: Sort and verify contiguous offsets (delivery order may vary)	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	780	// Step 3: Send 1 message to topic 2 with different source identifier	COMMENT
LOW	core/integration/tests/connectors/http/http_sink.rs	843	// 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	112	// Step 3: Restart server	COMMENT
LOW	core/server/src/metadata/consumer_group.rs	86	// Step 1: Assign unassigned partitions to idle members	COMMENT
LOW	core/server/src/metadata/consumer_group.rs	112	// Step 2: Mark excess partitions as pending revocation	COMMENT
LOW	core/server/src/metadata/reader.rs	268	// Step 1: Resolve group ID	COMMENT
LOW	core/server/src/metadata/reader.rs	318	// Step 2: Find member by client_id (same read guard, same metadata snapshot)	COMMENT
LOW	core/metadata/src/stm/consumer_group.rs	199	// Step 1: hand unassigned partitions straight to idle members.	COMMENT
LOW	core/metadata/src/stm/consumer_group.rs	222	// Step 2: mark excess on over-assigned members as pending revocation.	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	260	# Step 1: Publish iggy_binary_protocol (depends on nothing in-tree)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	289	# Step 2: Publish iggy_common (depends on iggy_binary_protocol)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	318	# Step 3: Publish iggy SDK (depends on common and protocol)	COMMENT
LOW	.github/workflows/_publish_rust_crates.yml	347	# 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
7 more matches not shown…

Hallucination Indicators8 hits · 80 pts

Severity	File	Line	Snippet	Context
CRITICAL	core/server/src/shard/mod.rs	176	if !self.config.system.logging.sysinfo_print_interval.is_zero() && self.id == 0 {	CODE
CRITICAL	…apache/iggy/client/blocking/tcp/TlsConnectionTest.java	153	org.apache.iggy.consumergroup.Consumer.of(0L),	CODE
CRITICAL	…che/iggy/client/async/AsyncConnectionPoolAuthTest.java	170	org.apache.iggy.identifier.TopicId.of("test-topic"),	CODE
CRITICAL	…che/iggy/client/async/AsyncConnectionPoolAuthTest.java	208	org.apache.iggy.identifier.TopicId.of("test-topic"),	CODE
CRITICAL	…che/iggy/client/async/AsyncConnectionPoolAuthTest.java	226	org.apache.iggy.identifier.TopicId.of("test-topic"),	CODE
CRITICAL	…/java/org/apache/iggy/serde/BytesDeserializerTest.java	566	.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	190	return Consumer.group(org.apache.iggy.identifier.ConsumerId.of(consumerGroupName));	CODE

Fake / Example Data34 hits · 36 pts

Severity	File	Line	Snippet	Context
LOW	README.md	342	Send another message 'lorem ipsum' (message ID 2) to the same stream, topic and partition:	CODE
LOW	README.md	344	`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	94	"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	2827	let dummy_id = Identifier::numeric(0).unwrap();	CODE
LOW⚡	…gration/tests/server/scenarios/permissions_scenario.rs	2831	IggyError::StreamIdNotFound(dummy_id.clone()).as_code(),	CODE
LOW⚡	…gration/tests/server/scenarios/permissions_scenario.rs	2833	IggyError::TopicIdNotFound(dummy_id.clone(), dummy_id.clone()).as_code(),	CODE
LOW⚡	…gration/tests/server/scenarios/permissions_scenario.rs	2883	let dummy_id = Identifier::numeric(0).unwrap();	CODE
LOW⚡	…gration/tests/server/scenarios/permissions_scenario.rs	2886	IggyError::StreamIdNotFound(dummy_id.clone()).as_code(),	CODE
LOW⚡	…gration/tests/server/scenarios/permissions_scenario.rs	2888	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

Redundant / Tautological Comments21 hits · 34 pts

Severity	File	Line	Snippet	Context
LOW	scripts/extract-version.sh	343	# 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	78	# Check if shellcheck is installed	COMMENT
LOW	scripts/ci/license-headers.sh	53	# Check if ASF_LICENSE.txt exists	COMMENT
LOW	scripts/ci/license-headers.sh	72	# Check if HawkEye is available	COMMENT
LOW	scripts/ci/taplo.sh	67	# Check if taplo is installed	COMMENT
LOW	scripts/ci/markdownlint.sh	66	# Check if markdownlint is installed	COMMENT
LOW	scripts/ci/trailing-newline.sh	130	# Check if file ends with a newline	COMMENT
LOW	scripts/dashboard/run_dev.sh	31	# Check if trunk is installed	COMMENT
LOW	scripts/performance/run-standard-performance-suite.sh	207	# Check if the server is running	COMMENT
LOW	scripts/performance/run-standard-performance-suite.sh	261	# Check if the server is running	COMMENT
LOW	.github/workflows/publish.yml	553	# 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	68	# Check if directory exists and has files	COMMENT
LOW	.github/actions/node-npm/post-merge/action.yml	123	# Check if files to be published exist	COMMENT

Cross-Language Confusion4 hits · 22 pts

Severity	File	Line	Snippet	Context
HIGH⚡	foreign/python/tests/test_message_operations.py	140	assert isinstance(msg.length(), int) and msg.length() > 0	CODE
HIGH	foreign/python/tests/test_message_operations.py	191	assert message.length() == len(expected_payload)	CODE
HIGH	foreign/python/tests/test_message_operations.py	231	assert message.length() == len(expected_payload)	CODE
HIGH	foreign/python/tests/test_message_operations.py	270	assert message.length() == len(payload)	CODE

AI Slop Vocabulary6 hits · 17 pts

Severity	File	Line	Snippet	Context
MEDIUM	core/connectors/sinks/doris_sink/src/lib.rs	539	/// `#[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/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	613	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	56	/// Future versions might utilize asyncio for more Pythonic async.	COMMENT

Excessive Try-Catch Wrapping12 hits · 13 pts

Severity	File	Line	Snippet	Context
LOW	examples/python/basic/producer.py	72	except Exception as error:	CODE
LOW	examples/python/basic/producer.py	89	except Exception as error:	CODE
LOW	examples/python/basic/producer.py	127	except Exception as error:	CODE
LOW	examples/python/basic/consumer.py	91	except Exception as error:	CODE
LOW	examples/python/getting-started/producer.py	138	except Exception as error:	CODE
LOW	examples/python/getting-started/producer.py	155	except Exception as error:	CODE
LOW	examples/python/getting-started/producer.py	193	except Exception as error:	CODE
LOW	examples/python/getting-started/consumer.py	125	except Exception as error:	CODE
LOW	examples/python/getting-started/consumer.py	160	except Exception as error:	CODE
LOW	foreign/python/tests/utils.py	103	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

Modern AI Meta-Vocabulary4 hits · 12 pts

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	406	// metadata checks skipped in scaffold	COMMENT

Magic Placeholder Names2 hits · 10 pts

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	80	api-key = "your-api-key"	CODE

Example Usage Blocks2 hits · 3 pts

Severity	File	Line	Snippet	Context
LOW	scripts/extract-version.sh	25	# Usage:	COMMENT
LOW	scripts/verify-crates-publish.sh	30	# Usage:	COMMENT

Self-Referential Comments1 hit · 3 pts

Severity	File	Line	Snippet	Context
MEDIUM	scripts/performance/run-standard-performance-suite.sh	97	# Create a directory for the performance results	COMMENT

TODO Padding1 hit · 2 pts

Severity	File	Line	Snippet	Context
LOW	core/simulator/src/packet.rs	497	// TODO: implement record/replay_recorded for deterministic replay support.	COMMENT

Analysis Overview

What These Metrics Mean

Score History

Severity Breakdown

Directory Score Breakdown

Pattern Findings