1.8

Adjusted Signal

1.8

Raw Pattern Score

100%

Time Factor

2026-10-31

Last Push

34.1K

Stars

Java

Language

1.8M

Lines of Code

7.3K

Files

1.7K

Pattern Hits

2026-10-31

Scan Date

0.02

HC Hit Rate

Risk Review · Payload v1

Use each vector to guide manual verification of the underlying findings.

Payload schema: 1.0.0 · Engine: 2.0.0 · Scoring: heuristic-density-v1 · Scan date: 2026-10-31.

Cognitive Ownership Risk 4.3/100 · LOW

Can maintainers explain intent, assumptions, and trade-offs? 1402 finding(s).

Hallucinated Dependency & Supply Chain Risk 4.0/100 · LOW

Are imports declared and package/API names verified? 206 finding(s).

Agent Over-Engineering Ratio 1.7/100 · LOW

Are wrappers, guards, and repeated structures necessary? 434 finding(s).

PR Review Velocity Impact 8.2/100 · LOW

Which changes need focused human review? 1699 finding(s).

What These Metrics Mean

Adjusted Signal: Legacy pattern score normalized per 1,000 scanned lines and multiplied by the repository-level time factor. It is not an estimate of AI authorship.
Raw Pattern Score: Sum of severity- and context-weighted pattern findings before applying the time factor.
Time Factor: A coarse multiplier based on repository last-push metadata. It does not identify when individual code was written.
Pattern Hits: Count of configured pattern findings. Review each location and surrounding code before acting.
HC Hit Rate: High- and critical-severity findings per scanned file. Severity is a configured detector weight, not proof of a vulnerability or authorship.
Lines / Files: Scan coverage denominators used by the legacy normalized score.

Pattern-Signal History

This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.

Severity Breakdown

Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.

CRITICAL 113HIGH 65MEDIUM 37LOW 1484

Directory Score Breakdown

This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.

Pattern Findings

The scanner identified 1699 distinct pattern matches across 21 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.

Hallucination Indicators113 hits · 1255 pts

Severity	File	Line	Snippet	Context
CRITICAL	…apache/kafka/clients/admin/StaticBrokerConfigTest.java	140	// broker (see org.apache.kafka.common.test.KafkaClusterTestKit.Builder.createNodeConfig()),	COMMENT
CRITICAL	…/kafka/clients/consumer/ShareConsumerCallbackTest.java	328	throw new org.apache.kafka.common.errors.OutOfOrderSequenceException("Exception thrown in Acknowledgemen	CODE
CRITICAL	…rg/apache/kafka/clients/producer/MockProducerTest.java	93	new org.apache.kafka.clients.producer.RoundRobinPartitioner(),	CODE
CRITICAL	…g/apache/kafka/clients/admin/KafkaAdminClientTest.java	1739	new org.apache.kafka.common.feature.SupportedVersionRange(versionRange.minVersion(),	CODE
CRITICAL	…lients/consumer/internals/ShareCompletedFetchTest.java	341	assertArrayEquals("key".getBytes(), org.apache.kafka.common.utils.Utils.toNullableArray(thrown.keyBuffer	CODE
CRITICAL	…ts/consumer/internals/ApplicationEventHandlerTest.java	98	org.apache.kafka.common.utils.Utils.sleep(delayMs);	CODE
CRITICAL	…a/common/record/internal/UnalignedFileRecordsTest.java	55	org.apache.kafka.common.requests.ByteBufferChannel channel = new org.apache.kafka.common.requests.ByteBufferChan	CODE
CRITICAL	…authbearer/ClientAssertionKeycloakIntegrationTest.java	134	org.junit.jupiter.api.Assumptions.assumeTrue(	CODE
CRITICAL	…authbearer/ClientAssertionKeycloakIntegrationTest.java	964	new org.apache.kafka.common.config.types.Password(passphrase));	CODE
CRITICAL	…authbearer/ClientAssertionKeycloakIntegrationTest.java	993	new org.apache.kafka.common.config.types.Password(passphrase));	CODE
CRITICAL	…authbearer/ClientAssertionKeycloakIntegrationTest.java	1024	new org.apache.kafka.common.config.types.Password(wrongPassphrase));	CODE
CRITICAL	…a/org/apache/kafka/clients/admin/KafkaAdminClient.java	4647	return new ScramFormatter(org.apache.kafka.common.security.scram.internals.ScramMechanism.forMechanismName(publi	CODE
CRITICAL	…/org/apache/kafka/clients/consumer/ConsumerConfig.java	415	" use <code>org.apache.kafka.clients.consumer.ShareConsumer.acknowledge()</code> to acknowledge delivery of	CODE
CRITICAL	…/org/apache/kafka/clients/consumer/ConsumerConfig.java	418	" <code>org.apache.kafka.clients.consumer.ShareConsumer.acknowledge()</code> to acknowledge delivery of reco	CODE
CRITICAL	…/src/main/java/org/apache/kafka/common/utils/Time.java	84	throw new org.apache.kafka.common.errors.TimeoutException("Condition not satisfied before deadline")	CODE
CRITICAL	…c/test/java/org/apache/kafka/tools/ToolsTestUtils.java	169	return org.apache.kafka.test.TestUtils.tempFile(sb.toString());	CODE
CRITICAL⚡	…rc/main/java/org/apache/kafka/tools/ConfigCommand.java	384	.map(mechanismName -> new UserScramCredentialDeletion(user, org.apache.kafka.clients.admin.ScramMechanis	CODE
CRITICAL⚡	…rc/main/java/org/apache/kafka/tools/ConfigCommand.java	392	org.apache.kafka.common.security.scram.internals.ScramMechanism.forMechanismName(mechanismNa	CODE
CRITICAL⚡	…rc/main/java/org/apache/kafka/tools/ConfigCommand.java	396	new ScramCredentialInfo(org.apache.kafka.clients.admin.ScramMechanism.fromMechanismName(mech	CODE
CRITICAL	…/main/java/org/apache/kafka/tools/DumpLogSegments.java	639	if (message.apiKey() == org.apache.kafka.coordinator.group.generated.CoordinatorRecordType.GROUP_METADATA.id	CODE
CRITICAL	…/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala	459	assertEquals(new org.apache.kafka.server.common.TopicIdPartition(topicId, t1p0.partition()), topicIdPartitionCapture	CODE
CRITICAL	…ala/unit/kafka/server/BrokerLifecycleManagerTest.scala	99	assertEquals(10L, context.mockChannelManager.unsentQueue.getFirst.request.build().asInstanceOf[BrokerRegistrationR	CODE
CRITICAL⚡	…it/kafka/server/StreamsGroupHeartbeatRequestTest.scala	797	val options = new org.apache.kafka.clients.admin.AlterConfigsOptions()	CODE
CRITICAL⚡	…it/kafka/server/StreamsGroupHeartbeatRequestTest.scala	807	val options2 = new org.apache.kafka.clients.admin.AlterConfigsOptions()	CODE
CRITICAL⚡	…it/kafka/server/StreamsGroupHeartbeatRequestTest.scala	817	val options3 = new org.apache.kafka.clients.admin.AlterConfigsOptions()	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	4489	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	4490	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	4535	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	4536	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	889	val metricsFromOldTests = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.filter(isProcessorMetric)	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1013	assertEquals(2, broker.config.dynamicConfig.reconfigurables.asScala.count(r => r.isInstanceOf[DataPlaneAcceptor]))	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1016	def acceptors: Seq[DataPlaneAcceptor] = broker.config.dynamicConfig.reconfigurables.asScala.filter(_.isInstanceOf[Da	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1322	Thread.getAllStackTraces.keySet.asScala.toList.map(_.getName)	CODE
CRITICAL	…ntegration/kafka/server/GssapiAuthenticationTest.scala	272	_ => org.apache.kafka.test.TestUtils.defaultApiVersionsResponse(ListenerType.BROKER)) {	CODE
CRITICAL	…src/test/scala/integration/kafka/api/MetricsTest.scala	221	def errorMetricCount = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.count(_.getName == "ErrorsPerSec	CODE
CRITICAL	…egration/kafka/api/PlaintextAdminIntegrationTest.scala	1284	val matching = client.listConsumerGroups.all.get.asScala.filter(group =>	CODE
CRITICAL	…egration/kafka/api/PlaintextAdminIntegrationTest.scala	1370	val matching = client.listConsumerGroups.all.get.asScala.filter(group =>	CODE
CRITICAL	…egration/kafka/api/PlaintextAdminIntegrationTest.scala	1556	val matching = client.listConsumerGroups.all.get.asScala.filter(group =>	CODE
CRITICAL	core/src/main/scala/kafka/cluster/Partition.scala	1693	new org.apache.kafka.server.common.TopicIdPartition(topicId.getOrElse(throw new IllegalStateException("Topic id no	CODE
CRITICAL	core/src/main/scala/kafka/server/KafkaApis.scala	2347	val renewerList = createTokenRequest.data.renewers.asScala.toList.map(entry =>	CODE
CRITICAL	…fka/coordinator/group/GroupCoordinatorServiceTest.java	174	Arguments.arguments(new org.apache.kafka.common.errors.TimeoutException(), Errors.COORDINATOR_NOT_AVAILABLE.	CODE
CRITICAL	…fka/coordinator/group/GroupCoordinatorServiceTest.java	529	Arguments.arguments(new org.apache.kafka.common.errors.TimeoutException(), Errors.COORDINATOR_NOT_AVAILABLE.	CODE
CRITICAL	…ache/kafka/coordinator/group/GroupMetadataManager.java	4202	StreamsGroupMember updatedMember = new org.apache.kafka.coordinator.group.streams.CurrentAssignmentBuilder(membe	CODE
CRITICAL	…ache/kafka/coordinator/group/GroupMetadataManager.java	4635	new org.apache.kafka.coordinator.group.streams.GroupSpecBuilder(assignmentConfigs)	CODE
CRITICAL	…ache/kafka/coordinator/group/GroupMetadataManager.java	4641	new org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder(groupEpoch, assignor)	CODE
CRITICAL	…ache/kafka/coordinator/group/GroupMetadataManager.java	6620	streamsGroup.updateTargetAssignment(memberId, org.apache.kafka.coordinator.group.streams.TasksTuple.fromTarg	CODE
CRITICAL	…s/integration/InMemoryStoreMetricsIntegrationTest.java	250	props.put(StreamsConfig.STATE_DIR_CONFIG, org.apache.kafka.test.TestUtils.tempDirectory().getAbsolutePath());	CODE
CRITICAL	…st/java/org/apache/kafka/streams/KafkaStreamsTest.java	314	org.apache.kafka.clients.consumer.CloseOptions.groupMembershipOperation(org.apache.kafka.clients.consume	CODE
CRITICAL	…st/java/org/apache/kafka/streams/KafkaStreamsTest.java	317	org.apache.kafka.clients.consumer.CloseOptions.groupMembershipOperation(org.apache.kafka.clients.consume	CODE
CRITICAL	…a/streams/processor/internals/StreamsProducerTest.java	110	= new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray	CODE
CRITICAL	…a/streams/processor/internals/StreamsProducerTest.java	112	= new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray	CODE
CRITICAL	…a/streams/processor/internals/RecordCollectorTest.java	152	= new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray	CODE
CRITICAL	…a/streams/processor/internals/RecordCollectorTest.java	1875	new org.apache.kafka.clients.producer.RoundRobinPartitioner(),	CODE
CRITICAL	…ssor/internals/assignment/TaskAssignmentUtilsTest.java	354	final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment noError = new org.apache.kafka.s	CODE
CRITICAL	…ssor/internals/assignment/TaskAssignmentUtilsTest.java	368	final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment missingProcessId = new org.apach	CODE
CRITICAL	…ssor/internals/assignment/TaskAssignmentUtilsTest.java	381	final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment unknownProcessId = new org.apach	CODE
CRITICAL	…ssor/internals/assignment/TaskAssignmentUtilsTest.java	396	final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment unknownTaskId = new org.apache.k	CODE
CRITICAL	…ssor/internals/assignment/TaskAssignmentUtilsTest.java	414	final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment activeTaskDuplicated = new org.a	CODE
CRITICAL⚡	…streams/state/internals/InMemoryKeyValueStoreTest.java	626	org.apache.kafka.streams.query.RangeQuery.withNoBounds(),	CODE
CRITICAL⚡	…streams/state/internals/InMemoryKeyValueStoreTest.java	627	org.apache.kafka.streams.query.PositionBound.unbounded(),	CODE
53 more matches not shown…

Over-Commented Block833 hits · 826 pts

Severity	File	Line	Snippet	Context
LOW	.asf.yaml	1	# Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	…ients-integration-tests/src/test/resources/log4j2.yaml	1	# Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	clients/src/test/resources/log4j2.yaml	1	# Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…resources/common/message/SimpleKeyedArraysMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…est/resources/common/message/SimpleExampleMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…st/resources/common/message/NullableStructMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…test/resources/common/message/SimpleArraysMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…est/resources/common/message/SimpleRecordsMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/src/test/resources/common/message/AllTypeMessage.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…l/CommonNameLoggingTrustManagerFactoryWrapperTest.java	81	// Self-signed	COMMENT
LOW	…ts/src/main/resources/common/message/VoteResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ces/common/message/DescribeDelegationTokenRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…es/common/message/DescribeTopicPartitionsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…esources/common/message/BrokerRegistrationRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ain/resources/common/message/DeleteRecordsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ources/common/message/AllocateProducerIdsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…rces/common/message/CreateDelegationTokenResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…sources/common/message/ShareGroupDescribeResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…sources/common/message/ShareGroupDescribeResponse.json	21	//	COMMENT
LOW	…src/main/resources/common/message/MetadataRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…src/main/resources/common/message/MetadataRequest.json	21	"validVersions": "0-13",	COMMENT
LOW	…ces/common/message/ControllerRegistrationResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…urces/common/message/AssignReplicasToDirsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/main/resources/common/message/ShareFetchResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/main/resources/common/message/ShareFetchResponse.json	21	//	COMMENT
LOW	…/resources/common/message/ShareAcknowledgeRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…c/main/resources/common/message/HeartbeatResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/main/resources/common/message/StopReplicaRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/src/main/resources/common/message/ProduceRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/src/main/resources/common/message/ProduceRequest.json	21	// Versions 0-2 were removed in Apache Kafka 4.0, version 3 is the new baseline. Due to a bug in librdkafka,	COMMENT
LOW	…main/resources/common/message/DeleteGroupsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…urces/common/message/WriteShareGroupStateResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…urces/common/message/WriteShareGroupStateResponse.json	21	//	COMMENT
LOW	…age/StreamsGroupTopologyDescriptionUpdateResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…age/StreamsGroupTopologyDescriptionUpdateResponse.json	21	"flexibleVersions": "0+",	COMMENT
LOW	…ces/common/message/DescribeTopicPartitionsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…s/src/main/resources/common/message/EndTxnRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…resources/common/message/AlterClientQuotasRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…in/resources/common/message/UpdateMetadataRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…rces/common/message/DeleteShareGroupStateResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…resources/common/message/UnregisterBrokerResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…n/resources/common/message/DescribeGroupsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/main/resources/common/message/LeaveGroupResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ents/src/main/resources/common/message/AbortedTxn.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ommon/message/DescribeUserScramCredentialsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…n/resources/common/message/FindCoordinatorRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…n/resources/common/message/FindCoordinatorRequest.json	21	// Version 1 adds KeyType.	COMMENT
LOW	…esources/common/message/AddPartitionsToTxnRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…sage/StreamsGroupTopologyDescriptionUpdateRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…esources/common/message/ShareGroupDescribeRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/resources/common/message/DescribeClusterResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ain/resources/common/message/SaslHandshakeRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…n/resources/common/message/DescribeLogDirsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ts/src/main/resources/common/message/FetchRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…ts/src/main/resources/common/message/FetchRequest.json	21	// Versions 0-3 were removed in Apache Kafka 4.0, Version 4 is the new baseline.	COMMENT
LOW	…ts/src/main/resources/common/message/FetchRequest.json	41	//	COMMENT
LOW	…s/common/message/GetTelemetrySubscriptionsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…sources/common/message/AlterReplicaLogDirsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…mmon/message/DescribeUserScramCredentialsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…in/resources/common/message/DescribeQuorumRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
773 more matches not shown…

Hyper-Verbose Identifiers330 hits · 343 pts

Severity	File	Line	Snippet	Context
LOW	…fka/clients/producer/internals/TransactionManager.java	1403	abstract class TxnRequestHandler implements RequestCompletionHandler {	CODE
LOW	…ka/clients/consumer/internals/ConsumerCoordinator.java	1352	private class OffsetCommitResponseHandler extends CoordinatorResponseHandler<OffsetCommitResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/ConsumerCoordinator.java	1514	private class OffsetFetchResponseHandler extends CoordinatorResponseHandler<OffsetFetchResponse, Map<TopicPartition,	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	640	private class JoinGroupResponseHandler extends CoordinatorResponseHandler<JoinGroupResponse, ByteBuffer> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	820	private class SyncGroupResponseHandler extends CoordinatorResponseHandler<SyncGroupResponse, ByteBuffer> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	922	private class FindCoordinatorResponseHandler extends RequestFutureAdapter<ClientResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1200	private class LeaveGroupResponseHandler extends CoordinatorResponseHandler<LeaveGroupResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1238	private class HeartbeatResponseHandler extends CoordinatorResponseHandler<HeartbeatResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1292	protected abstract class CoordinatorResponseHandler<R, T> extends RequestFutureAdapter<ClientResponse, T> {	CODE
LOW	docker/extract_docker_official_image_artifact.py	40	def set_executable_permissions(directory):	CODE
LOW	docker/common.py	58	def build_docker_image_runner(command, image_type, kafka_archive=None):	CODE
LOW	docker/prepare_docker_official_image_source.py	49	def remove_args_and_hardcode_values(file_path, kafka_version, kafka_url):	CODE
LOW	docker/docker_official_image_build_test.py	44	def build_docker_official_image(image, tag, kafka_version, image_type):	CODE
LOW	docker/test/docker_sanity_test.py	89	def set_share_group_offset_reset_strategy(self, group_id, strategy, command_config):	CODE
LOW	docker/test/docker_sanity_test.py	166	def consumer_group_protocol_flow(self):	CODE
LOW	docker/test/docker_sanity_test.py	186	def share_group_protocol_flow(self):	CODE
LOW	…a/coordinator/AbstractCoordinatorConcurrencyTest.scala	278	def getOrCreateLogs(): mutable.Map[TopicPartition, (UnifiedLog, Long)] = {	CODE
LOW	…er/handlers/DescribeTopicPartitionsRequestHandler.java	43	public class DescribeTopicPartitionsRequestHandler {	CODE
LOW	…rc/main/scala/kafka/tools/TestRaftRequestHandler.scala	36	class TestRaftRequestHandler(	CODE
LOW	…/coordinator/transaction/TransactionStateManager.scala	414	private def getAndMaybeAddTransactionState(transactionalId: String,	CODE
LOW	core/src/main/scala/kafka/network/SocketServer.scala	1575	private def getOrCreateConnectionRateQuotaSensor(quotaLimit: Int, connectionQuotaEntity: ConnectionQuotaEntity): Senso	CODE
LOW	core/src/main/scala/kafka/server/ReplicaManager.scala	2318	private[kafka] def getOrCreatePartition(tp: TopicPartition,	CODE
LOW	…/src/main/scala/kafka/server/KafkaRequestHandler.scala	91	class KafkaRequestHandler(	CODE
LOW	…rc/main/scala/kafka/server/AbstractFetcherThread.scala	838	def getAndMaybePut(topicPartition: TopicPartition): FetcherLagMetrics = {	CODE
LOW	core/src/main/scala/kafka/server/ConfigHandler.scala	159	def getOrDefault(prop: String): Long = updatedDynamicBrokerConfigs get prop match {	CODE
LOW	tests/unit/directory_layout/check_project_paths.py	37	def check_create_path_resolver_override(self):	CODE
LOW	tests/unit/directory_layout/check_project_paths.py	49	def check_create_path_resolver_default(self):	CODE
LOW	tests/unit/directory_layout/check_project_paths.py	63	def check_versioned_source_paths(self):	CODE
LOW	tests/unit/directory_layout/check_project_paths.py	71	def check_node_or_version_helper(self):	CODE
LOW⚡	tests/kafkatest/version.py	65	def topic_command_supports_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	68	def topic_command_supports_if_not_exists_with_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	71	def supports_tls_to_zookeeper(self):	CODE
LOW⚡	tests/kafkatest/version.py	75	def reassign_partitions_command_supports_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	78	def kafka_configs_command_uses_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	82	def kafka_configs_command_uses_bootstrap_server_scram(self):	CODE
LOW⚡	tests/kafkatest/version.py	86	def supports_topic_ids_when_using_zk(self):	CODE
LOW⚡	tests/kafkatest/version.py	107	def supports_command_property(self):	CODE
LOW⚡	tests/kafkatest/version.py	114	def supports_formatter_property(self):	CODE
LOW⚡	tests/kafkatest/version.py	121	def supports_consumer_close_timeout(self):	CODE
LOW	…ts/kafkatest/sanity_checks/test_verifiable_producer.py	84	def test_multiple_kraft_security_protocols(	CODE
LOW	…ts/kafkatest/sanity_checks/test_verifiable_producer.py	125	def test_multiple_kraft_sasl_mechanisms(self, metadata_quorum):	CODE
LOW⚡	tests/kafkatest/tests/verifiable_share_consumer_test.py	78	def await_consumed_messages_by_a_consumer(self, consumer, node, min_messages=1, timeout_sec=10, total=False):	CODE
LOW⚡	tests/kafkatest/tests/verifiable_share_consumer_test.py	86	def await_unique_consumed_messages(self, consumer, min_messages=1, timeout_sec=10):	CODE
LOW⚡	tests/kafkatest/tests/verifiable_share_consumer_test.py	91	def await_acknowledged_messages(self, consumer, min_messages=1, timeout_sec=10):	CODE
LOW⚡	tests/kafkatest/tests/verifiable_share_consumer_test.py	96	def await_unique_acknowledged_messages(self, consumer, min_messages=1, timeout_sec=10):	CODE
LOW	tests/kafkatest/tests/produce_consume_validate.py	51	def start_producer_and_consumer(self):	CODE
LOW	tests/kafkatest/tests/produce_consume_validate.py	93	def stop_producer_and_consumer(self):	CODE
LOW	tests/kafkatest/tests/produce_consume_validate.py	99	def run_produce_consume_validate(self, core_test_action=None, *args):	CODE
LOW	tests/kafkatest/tests/end_to_end.py	45	def create_zookeeper_if_necessary(self, num_nodes=1, **kwargs):	CODE
LOW	tests/kafkatest/tests/verifiable_consumer_test.py	89	def await_all_members_stabilized(self, topic, num_partitions, consumer, timeout_sec):	CODE
LOW	tests/kafkatest/tests/tools/log_compaction_test.py	52	def start_test_log_compaction_tool(self, security_protocol, compression_config={}):	CODE
LOW	tests/kafkatest/tests/tools/trogdor_test.py	72	def test_network_partition_fault(self):	CODE
LOW	…sts/kafkatest/tests/tools/replica_verification_test.py	60	def start_replica_verification_tool(self, security_protocol):	CODE
LOW	tests/kafkatest/tests/core/fetch_from_follower_test.py	73	def test_consumer_preferred_read_replica(self, metadata_quorum, group_protocol=None):	CODE
LOW	tests/kafkatest/tests/core/transactions_test.py	141	def copy_messages_transactionally(self, failure_mode, bounce_target,	CODE
LOW	…fkatest/tests/core/transactions_mixed_versions_test.py	115	def copy_messages_transactionally(self, input_topic, output_topic,	CODE
LOW	…fkatest/tests/core/transactions_mixed_versions_test.py	198	def test_transactions_mixed_versions(self, old_kafka_version, metadata_quorum=quorum.isolated_kraft, group_protocol=	CODE
LOW	tests/kafkatest/tests/core/share_consume_bench_test.py	96	def test_two_share_consumers_in_a_group_topics(self, metadata_quorum):	CODE
LOW	tests/kafkatest/tests/core/share_consume_bench_test.py	124	def test_one_share_consumer_subscribed_to_single_topic(self, metadata_quorum):	CODE
LOW	tests/kafkatest/tests/core/share_consume_bench_test.py	151	def test_multiple_share_consumers_subscribed_to_single_topic(self, metadata_quorum):	CODE
270 more matches not shown…

Cross-File Repetition31 hits · 155 pts

Severity	File	Snippet	Context
HIGH	tests/kafkatest/tests/verifiable_share_consumer_test.py	override this since we're adding services outside of the constructor	STRING
HIGH	tests/kafkatest/tests/verifiable_consumer_test.py	override this since we're adding services outside of the constructor	STRING
HIGH	tests/kafkatest/tests/core/log_dir_failure_test.py	override this since we're adding services outside of the constructor	STRING
HIGH	tests/kafkatest/tests/core/replication_test.py	override this since we're adding services outside of the constructor	STRING
HIGH	tests/kafkatest/tests/core/quota_test.py	override this since we're adding services outside of the constructor	STRING
HIGH	tests/kafkatest/tests/core/transactions_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…fkatest/tests/core/transactions_mixed_versions_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/share_consume_bench_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/security_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/produce_bench_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…fkatest/tests/core/replication_replica_failure_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/log_dir_failure_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/throttling_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/round_trip_fault_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/consume_bench_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/replication_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…s/kafkatest/tests/core/group_mode_transactions_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/reassign_partitions_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/transactions_upgrade_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/core/quota_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…/kafkatest/tests/core/eligible_leader_replicas_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…est/tests/client/client_compatibility_features_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	tests/kafkatest/tests/client/compression_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…ts/client/client_compatibility_produce_consume_test.py	:type test_context: ducktape.tests.test.testcontext	STRING
HIGH	…sts/kafkatest/services/transactional_message_copier.py	try to parse a string as json. return none if not parseable.	STRING
HIGH	tests/kafkatest/services/verifiable_consumer.py	try to parse a string as json. return none if not parseable.	STRING
HIGH	tests/kafkatest/services/verifiable_producer.py	try to parse a string as json. return none if not parseable.	STRING
HIGH	tests/kafkatest/services/verifiable_share_consumer.py	try to parse a string as json. return none if not parseable.	STRING
HIGH	tests/kafkatest/services/verifiable_consumer.py	this service wraps org.apache.kafka.tools.verifiableshareconsumer for use in system testing. note: this class should be	STRING
HIGH	tests/kafkatest/services/verifiable_producer.py	this service wraps org.apache.kafka.tools.verifiableshareconsumer for use in system testing. note: this class should be	STRING
HIGH	tests/kafkatest/services/verifiable_share_consumer.py	this service wraps org.apache.kafka.tools.verifiableshareconsumer for use in system testing. note: this class should be	STRING

Structural Annotation Overuse84 hits · 150 pts

Severity	File	Line	Snippet	Context
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1955	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1964	// Step 5: receive an empty assignment, which means we should call revoke	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1972	// Step 6: revoke partitions	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1982	// Step 7: assign partitions should still be called, even though it's empty	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1992	// Step 8: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	2351	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	2360	// Step 3: invoke the callback	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	1929	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	1944	// Step 3: assign partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2010	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2026	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2041	// Step 3: revoke partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2053	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2070	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2085	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2100	// Step 3: revoke partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2111	// Step 4: assign partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2123	// Step 5: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2336	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2371	// Step 4: Receive ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	112	// Step 1: mark the coordinator as disconnected right after creation of the CoordinatorRequestManager.	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	117	// Step 2: sleep for one minute and mark the coordinator unknown again. Then verify that the warning was	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	125	// Step 3: sleep for another minute, mark the coordinator unknown again, and verify the accuracy.	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	528	// Step 1: Authenticate with client assertion	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	538	// Step 2: Reconfigure with only client secret (assertion configs removed)	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	560	// Step 1: Authenticate with locally-generated assertion	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	570	// Step 2: Reconfigure with file-based assertion (locally-generated configs removed)	COMMENT
LOW	…authbearer/ClientAssertionKeycloakIntegrationTest.java	600	// Step 1: Authenticate with file-based assertion	COMMENT
LOW	…authbearer/ClientAssertionKeycloakIntegrationTest.java	620	// Step 2: Reconfigure with locally-generated assertion (file config removed)	COMMENT
LOW	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1476	// Step 1: Send client requests.	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1487	// Step 2: Close the client-side socket and the proxy socket to the server, triggering close notification in the	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1497	// Step 3: Process the first request. Verify that the channel is not removed since the channel	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1504	// Step 4: Process buffered data. if `responseRequiredIndex>=0`, the channel should be failed and removed when	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	70	// Step 1: Generate the key pair dynamically.	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	77	// Step 2: Create the RSA JWK from key pair.	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	83	// Step 3: Create the OAuth server using the keys just created	COMMENT
LOW⚡	…e/src/main/java/kafka/server/share/SharePartition.java	3378	// Step 1: Enqueue to DLQ	COMMENT
LOW⚡	…e/src/main/java/kafka/server/share/SharePartition.java	3387	// Step 2: Transition ARCHIVING → ARCHIVED	COMMENT
LOW	…e/src/main/java/kafka/server/share/SharePartition.java	3400	// Step 3: Persist ARCHIVED. On failure, ARCHIVED stays in memory — the	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	202	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	215	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	220	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	240	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	256	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	261	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	155	// Step 1: Initial Topology Start	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	159	// Step 2: Create Non-Joined Records	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	187	// Step 3: Force State Restoration	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	191	// Step 4: Restart with Restoration	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	195	// Step 5: Trigger Window Advancement	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	285	// Step 1: Create a plain store with two keys	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	292	// Step 2: Open as timestamped store and migrate one key (simulating partial migration)	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	299	// Step 3: Try to open with headers store - should fail	COMMENT
LOW	release/release.py	261	# Step 1: Trigger build/test workflows and loop until CVE-free	COMMENT
LOW	release/release.py	273	# Step 2: Push RC images to DockerHub	COMMENT
LOW	docs/streams/quickstart.md	67	### Step 1: Download the code	COMMENT
LOW	docs/streams/quickstart.md	75	### Step 2: Start the Kafka server	COMMENT
LOW	docs/streams/quickstart.md	92	### Step 3: Prepare input topic and start Kafka producer	COMMENT
LOW	docs/streams/quickstart.md	124	### Step 4: Start the Wordcount Application	COMMENT
LOW	docs/streams/quickstart.md	155	### Step 5: Process some data	COMMENT
24 more matches not shown…

Cross-Language Confusion23 hits · 142 pts

Severity	File	Line	Snippet	Context
HIGH⚡	…t/tests/streams/streams_protocol_cross_version_test.py	147	cmd = "grep -c -F -- '%s' %s 2>/dev/null \|\| true" % (literal, path)	CODE
HIGH⚡	…t/tests/streams/streams_protocol_cross_version_test.py	163	cmd = "grep -c -E -- '%s' %s 2>/dev/null \|\| true" % (self.OLD_BROKER_REJECTION_PATTERN, path)	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	109	"grep -c '%s' %s \|\| true" % (self.BROKER_SOLICITED_LOG, self.BROKER_LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	115	"grep -c '%s' %s \|\| true" % (self.PUSH_REQUESTED_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	121	"grep -c '%s' %s \|\| true" % (self.PUSH_SENDING_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	127	"grep -c '%s' %s \|\| true" % (self.PUSH_SUCCESS_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	151	"grep -c '%s' %s \|\| true" % (self.PUSH_REQUESTED_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	157	"grep -c '%s' %s \|\| true" % (self.PUSH_SENDING_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	163	"grep -c '%s' %s \|\| true" % (self.PUSH_SUCCESS_LOG, processor.LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	263	"grep -c '%s' %s \|\| true" % (self.BROKER_SOLICITED_LOG, self.BROKER_LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	272	"grep -c '%s' %s \|\| true" % (self.BROKER_SOLICITED_LOG, self.BROKER_LOG_FILE),	CODE
HIGH⚡	…ts/streams/streams_topology_description_plugin_test.py	278	"grep -c '%s' %s \|\| true" % (self.PUSH_SUCCESS_LOG, processor.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	191	"grep -c '%s' %s \|\| true" % (self.PUSH_REQUESTED_LOG, processor.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	197	"grep -c '%s' %s \|\| true" % (self.PUSH_SENDING_LOG, processor.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	250	"grep -c '%s' %s \|\| true" % (self.BROKER_SOLICITED_LOG, self.BROKER_LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	309	"grep -c '%s' %s \|\| true" % (self.PUSH_SUCCESS_LOG, processor1.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	312	"grep -c '%s' %s \|\| true" % (self.PUSH_SUCCESS_LOG, processor2.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	326	"grep -c '%s' %s \|\| true" % (self.PUSH_SENDING_LOG, processor1.LOG_FILE),	CODE
HIGH	…ts/streams/streams_topology_description_plugin_test.py	329	"grep -c '%s' %s \|\| true" % (self.PUSH_SENDING_LOG, processor2.LOG_FILE),	CODE
HIGH	tests/kafkatest/tests/streams/streams_smoke_test.py	167	"grep -c 'Requested topology description push at topology epoch' %s \|\| true" % broker_log,	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	1461	cmd += "&& sleep 1 && rm -f %s" % json_file	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	1503	cmd += " && sleep 1 && rm -f %s" % json_file	CODE
HIGH	release/test_gh_actions.py	21	or: cd release && python -m pytest test_gh_actions.py -v	STRING

Verbosity Indicators72 hits · 132 pts

Severity	File	Line	Snippet	Context
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1955	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1964	// Step 5: receive an empty assignment, which means we should call revoke	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1972	// Step 6: revoke partitions	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1982	// Step 7: assign partitions should still be called, even though it's empty	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	1992	// Step 8: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	2351	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW⚡	…/consumer/internals/ConsumerMembershipManagerTest.java	2360	// Step 3: invoke the callback	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	1929	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	1944	// Step 3: assign partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2010	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2026	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2041	// Step 3: revoke partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2053	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2070	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2085	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2100	// Step 3: revoke partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2111	// Step 4: assign partitions	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2123	// Step 5: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2336	// Step 1: set up mocks	COMMENT
LOW	…/consumer/internals/ConsumerMembershipManagerTest.java	2371	// Step 4: Receive ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	112	// Step 1: mark the coordinator as disconnected right after creation of the CoordinatorRequestManager.	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	117	// Step 2: sleep for one minute and mark the coordinator unknown again. Then verify that the warning was	COMMENT
LOW⚡	…/consumer/internals/CoordinatorRequestManagerTest.java	125	// Step 3: sleep for another minute, mark the coordinator unknown again, and verify the accuracy.	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	528	// Step 1: Authenticate with client assertion	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	538	// Step 2: Reconfigure with only client secret (assertion configs removed)	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	560	// Step 1: Authenticate with locally-generated assertion	COMMENT
LOW⚡	…authbearer/ClientAssertionKeycloakIntegrationTest.java	570	// Step 2: Reconfigure with file-based assertion (locally-generated configs removed)	COMMENT
LOW	…authbearer/ClientAssertionKeycloakIntegrationTest.java	600	// Step 1: Authenticate with file-based assertion	COMMENT
LOW	…authbearer/ClientAssertionKeycloakIntegrationTest.java	620	// Step 2: Reconfigure with locally-generated assertion (file config removed)	COMMENT
LOW	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1476	// Step 1: Send client requests.	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1487	// Step 2: Close the client-side socket and the proxy socket to the server, triggering close notification in the	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1497	// Step 3: Process the first request. Verify that the channel is not removed since the channel	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1504	// Step 4: Process buffered data. if `responseRequiredIndex>=0`, the channel should be failed and removed when	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	70	// Step 1: Generate the key pair dynamically.	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	77	// Step 2: Create the RSA JWK from key pair.	COMMENT
LOW⚡	…integration/kafka/api/ClientOAuthIntegrationTest.scala	83	// Step 3: Create the OAuth server using the keys just created	COMMENT
LOW	…e/src/main/java/kafka/server/share/SharePartition.java	1725	// we need to check if the share partition has reached the max in-flight records limit	COMMENT
LOW⚡	…e/src/main/java/kafka/server/share/SharePartition.java	3378	// Step 1: Enqueue to DLQ	COMMENT
LOW⚡	…e/src/main/java/kafka/server/share/SharePartition.java	3387	// Step 2: Transition ARCHIVING → ARCHIVED	COMMENT
LOW	…e/src/main/java/kafka/server/share/SharePartition.java	3400	// Step 3: Persist ARCHIVED. On failure, ARCHIVED stays in memory — the	COMMENT
LOW	…rc/main/java/kafka/server/share/DelayedShareFetch.java	239	// may or may not have completed. We need to check if the async read has completed to decide	COMMENT
LOW	…rc/main/java/kafka/server/share/DelayedShareFetch.java	298	// If tryComplete did not invoke forceComplete, so we need to check if we have any partitions to fetch.	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	202	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	215	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	220	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	240	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	256	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	261	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	155	// Step 1: Initial Topology Start	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	159	// Step 2: Create Non-Joined Records	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	187	// Step 3: Force State Restoration	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	191	// Step 4: Restart with Restoration	COMMENT
LOW⚡	…ntegration/OuterJoinListValueStoreRestorationTest.java	195	// Step 5: Trigger Window Advancement	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	285	// Step 1: Create a plain store with two keys	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	292	// Step 2: Open as timestamped store and migrate one key (simulating partial migration)	COMMENT
LOW⚡	…/internals/RocksDBTimestampedStoreWithHeadersTest.java	299	// Step 3: Try to open with headers store - should fail	COMMENT
LOW	…ache/kafka/server/share/session/ShareSessionCache.java	288	// as part of final epoch from client, so we need to check if the session is still	COMMENT
LOW	release/release.py	261	# Step 1: Trigger build/test workflows and loop until CVE-free	COMMENT
LOW	release/release.py	273	# Step 2: Push RC images to DockerHub	COMMENT
LOW⚡	…apache/kafka/storage/internals/log/UnifiedLogTest.java	4809	// Step 1: Write transactional records as leader to establish current epoch	COMMENT
12 more matches not shown…

Excessive Try-Catch Wrapping50 hits · 66 pts

Severity	File	Line	Snippet	Context
LOW	docker/common.py	76	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	265	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	270	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	275	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	280	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	285	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	290	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	295	except Exception as e:	CODE
LOW	…est/tests/client/client_compatibility_features_test.py	52	except Exception as e:	CODE
LOW	…est/tests/client/client_compatibility_features_test.py	104	except Exception as e:	CODE
LOW⚡	tests/kafkatest/tests/client/share_consumer_test.py	63	except Exception:	CODE
MEDIUM	tests/kafkatest/tests/client/share_consumer_test.py	59	def leader_settled(partition_leader, topicName, partition):	CODE
LOW	tests/kafkatest/services/streams.py	236	except Exception as exception:	CODE
MEDIUM	tests/kafkatest/services/streams.py	232	def pids(self, node):	CODE
LOW	tests/kafkatest/services/monitor/http.py	209	except Exception as e:	CODE
MEDIUM	tests/kafkatest/services/monitor/http.py	96	def stop(self):	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	700	except Exception:	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	705	except Exception:	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	1016	except Exception:	CODE
LOW	release/release.py	310	except Exception as e:	CODE
LOW	release/release.py	379	except Exception as e:	CODE
MEDIUM	release/release.py	303	def prereq(name, soft_check):	CODE
LOW	release/runtime.py	58	except Exception as e:	CODE
LOW	release/notes.py	172	except Exception as e:	STRING
LOW	release/gpg.py	35	except Exception:	CODE
LOW	.github/scripts/pr-reviewers-trailer.py	101	except Exception as e:	CODE
MEDIUM	.github/scripts/pr-reviewers-trailer.py	95	def _run_json(cmd, source):	CODE
MEDIUM	.github/scripts/develocity_reports.py	1289	print(f"Error occurred: {str(e)}")	CODE
MEDIUM	.github/scripts/develocity_reports.py	108	def get_cache(self) -> Optional[BuildCache]:	CODE
MEDIUM	.github/scripts/develocity_reports.py	128	def get_cache(self) -> Optional[BuildCache]:	CODE
LOW⚡	.github/scripts/develocity_reports.py	113	except Exception as e:	CODE
LOW⚡	.github/scripts/develocity_reports.py	121	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	141	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	155	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	394	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	598	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	818	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	914	except Exception as e:	CODE
LOW	.github/scripts/develocity_reports.py	1287	except Exception as e:	CODE
LOW	committer-tools/refresh_collaborators.py	149	except Exception as e:	CODE
MEDIUM	committer-tools/verify_license.py	45	print("Error: Distributions directory not found:", distributions_dir)	CODE
MEDIUM	committer-tools/verify_license.py	55	print("Error: No tarball matching 'kafka_2.13-*.tgz' found in:", distributions_dir)	CODE
MEDIUM	committer-tools/verify_license.py	100	print("Error: No directory found after extraction.")	CODE
MEDIUM	committer-tools/verify_license.py	109	print("Error: LICENSE file or libs directory not found in the extracted project.")	CODE
LOW	committer-tools/kafka-merge-pr.py	142	except Exception as error:	CODE
LOW	committer-tools/kafka-merge-pr.py	202	except Exception as error:	CODE
LOW	committer-tools/kafka-merge-pr.py	225	except Exception as error:	CODE
LOW	committer-tools/kafka-merge-pr.py	236	except Exception as error:	CODE
LOW	committer-tools/kafka-merge-pr.py	274	except Exception as error:	CODE
MEDIUM	committer-tools/kafka-merge-pr.py	77	def get_json(url):	CODE

Unused Imports61 hits · 60 pts

Severity	File	Line	Context
LOW	docker/generate_kafka_pr_template.py	36	CODE
LOW	…s/kafkatest/sanity_checks/test_performance_services.py	17	CODE
LOW	…fkatest/tests/core/transactions_mixed_versions_test.py	20	CODE
LOW	…fkatest/tests/core/transactions_mixed_versions_test.py	23	CODE
LOW	…fkatest/tests/core/transactions_mixed_versions_test.py	32	CODE
LOW	…fkatest/tests/core/replication_replica_failure_test.py	20	CODE
LOW	…fkatest/tests/core/replication_replica_failure_test.py	25	CODE
LOW	…fkatest/tests/core/replication_replica_failure_test.py	27	CODE
LOW	…fkatest/tests/core/replication_replica_failure_test.py	30	CODE
LOW	…fkatest/tests/core/replication_replica_failure_test.py	31	CODE
LOW	tests/kafkatest/tests/core/round_trip_fault_test.py	27	CODE
LOW	tests/kafkatest/tests/core/replication_test.py	19	CODE
LOW	…atest/tests/core/compatibility_test_new_broker_test.py	13	CODE
LOW	tests/kafkatest/tests/core/upgrade_test.py	16	CODE
LOW	tests/kafkatest/tests/core/upgrade_test.py	20	CODE
LOW	tests/kafkatest/tests/core/snapshot_test.py	16	CODE
LOW	tests/kafkatest/tests/core/transactions_upgrade_test.py	20	CODE
LOW	tests/kafkatest/tests/core/transactions_upgrade_test.py	32	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	18	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	22	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	25	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	25	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	25	CODE
LOW	…est/tests/streams/streams_broker_compatibility_test.py	16	CODE
LOW	…test/tests/streams/streams_application_upgrade_test.py	23	CODE
LOW	…test/tests/streams/streams_application_upgrade_test.py	23	CODE
LOW	tests/kafkatest/tests/streams/utils/__init__.py	16	CODE
LOW	tests/kafkatest/tests/streams/utils/__init__.py	16	CODE
LOW	tests/kafkatest/tests/streams/utils/__init__.py	16	CODE
LOW	tests/kafkatest/tests/streams/utils/__init__.py	16	CODE
LOW	tests/kafkatest/tests/streams/utils/__init__.py	16	CODE
LOW	tests/kafkatest/tests/connect/connect_test.py	23	CODE
LOW	…atest/tests/client/consumer_protocol_migration_test.py	21	CODE
LOW	tests/kafkatest/tests/client/consumer_test.py	21	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/utils/__init__.py	16	CODE
LOW	tests/kafkatest/services/console_consumer.py	24	CODE
LOW	tests/kafkatest/services/console_share_consumer.py	20	CODE
LOW	tests/kafkatest/services/console_share_consumer.py	24	CODE
LOW	tests/kafkatest/services/monitor/jmx.py	22	CODE
LOW	tests/kafkatest/services/security/kafka_acls.py	16	CODE
LOW	tests/kafkatest/services/kafka/__init__.py	16	CODE
LOW	tests/kafkatest/services/kafka/__init__.py	17	CODE
LOW	tests/kafkatest/services/kafka/__init__.py	18	CODE
LOW	tests/kafkatest/services/performance/__init__.py	16	CODE
LOW	tests/kafkatest/services/performance/__init__.py	16	CODE
LOW	tests/kafkatest/services/performance/__init__.py	16	CODE
LOW	tests/kafkatest/services/performance/__init__.py	16	CODE
LOW	tests/kafkatest/services/performance/__init__.py	17	CODE
LOW	tests/kafkatest/services/performance/__init__.py	18	CODE
LOW	tests/kafkatest/services/performance/__init__.py	19	CODE
LOW	tests/kafkatest/services/performance/__init__.py	20	CODE
LOW	release/release.py	57	CODE
LOW	release/svn.py	24	CODE
LOW	.github/scripts/checkstyle.py	21	CODE
LOW	.github/scripts/develocity_reports.py	20	CODE
1 more matches not shown…

AI Slop Vocabulary18 hits · 46 pts

Severity	File	Line	Snippet	Context
MEDIUM	…a/org/apache/kafka/clients/producer/KafkaProducer.java	781	* {@link KafkaConsumer#groupMetadata()} to leverage consumer group metadata. This will provide	COMMENT
MEDIUM	…a/org/apache/kafka/clients/admin/KafkaAdminClient.java	5037	// Simply leverage the existing fenceProducers implementation with a single transactional ID	COMMENT
LOW	…a/org/apache/kafka/clients/consumer/KafkaConsumer.java	319	* To use this mode, instead of subscribing to the topic using {@link #subscribe(Collection) subscribe}, you just call	COMMENT
LOW	…a/org/apache/kafka/clients/consumer/KafkaConsumer.java	655	* partitions using {@link #assign(Collection)} then this will simply return the same partitions that	COMMENT
LOW	…org/apache/kafka/common/internals/KafkaFutureImpl.java	65	// function. CompletableFuture#thenApply will just return ExecutionException wrapping the	COMMENT
MEDIUM	core/src/main/scala/kafka/server/ReplicaManager.scala	893	// Please refer to the documentation in `DelayedProduce#tryComplete` for a comprehensive description of thes	COMMENT
MEDIUM	…ache/kafka/coordinator/group/GroupMetadataManager.java	4706	// just apply the target assignment directly. It's a robust fall back, ensuring that we converge to the new	COMMENT
LOW	vagrant/base.sh	209	# VMs, we can just create it if it doesn't exist and use it like we'd use	COMMENT
MEDIUM	…/streams/processor/internals/StoreChangelogReader.java	135	// NOTE we do not book keep the current offset since we leverage state manager as its source of truth	COMMENT
LOW	tests/kafkatest/tests/core/transactions_test.py	226	# To check ordering, we simply create input and output topics	COMMENT
MEDIUM	tests/kafkatest/tests/core/reassign_partitions_test.py	137	# latter is more robust.	COMMENT
MEDIUM	…t/tests/streams/streams_protocol_cross_version_test.py	58	# Topics the StreamsUpgradeTest harness reads from and writes to.	COMMENT
MEDIUM	…t/tests/streams/streams_protocol_cross_version_test.py	62	# application.id hard-coded by the StreamsUpgradeTest harness, in every version.	COMMENT
MEDIUM	…t/tests/streams/streams_protocol_cross_version_test.py	109	# The harness configures session.timeout.ms=10000, which is below the default lower bound.	COMMENT
MEDIUM	…t/tests/streams/streams_protocol_cross_version_test.py	131	# installed release, which is how the harness selects the DEV client.	COMMENT
MEDIUM	…/kafkatest/tests/streams/streams_broker_bounce_test.py	187	# Start test harness	COMMENT
MEDIUM	tests/kafkatest/services/monitor/jmx.py	63	# JmxTool is not particularly robust to slow-starting processes. In order to ensure JmxTool doesn't fail if the	COMMENT
MEDIUM	…he/kafka/connect/runtime/WorkerTransactionContext.java	83	// Essentially, instead of telling the task that it screwed up and trusting it to do the right thing, we rat on	COMMENT

Empty Error Handlers8 hits · 40 pts

Severity	File	Line	Snippet	Context
HIGH	docker/common.py	39	except FileNotFoundError:	CODE
HIGH	tests/kafkatest/tests/core/security_test.py	171	except TimeoutError:	CODE
HIGH	tests/kafkatest/tests/core/security_test.py	119	except TimeoutError:	CODE
HIGH	tests/kafkatest/tests/connect/connect_rest_test.py	135	except ConnectRestError:	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	700	except Exception:	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	705	except Exception:	CODE
HIGH	…kafkatest/services/performance/producer_performance.py	147	except:	CODE
HIGH	release/gh_actions.py	49	except GithubException:	CODE

Deep Nesting31 hits · 25 pts

Severity	File	Line	Context
LOW	tests/kafkatest/tests/core/quota_test.py	33	CODE
LOW	…katest/tests/streams/streams_static_membership_test.py	70	CODE
LOW	…katest/tests/streams/streams_static_membership_test.py	134	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	255	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	334	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	416	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	566	CODE
LOW	…sts/kafkatest/services/transactional_message_copier.py	76	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	95	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	316	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	376	CODE
LOW	tests/kafkatest/services/verifiable_producer.py	125	CODE
LOW	tests/kafkatest/services/verifiable_share_consumer.py	161	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	194	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	601	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	844	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	1515	CODE
LOW	release/textfiles.py	55	CODE
LOW	.github/scripts/format-test-catalog.py	32	CODE
LOW	.github/scripts/checkstyle.py	38	CODE
LOW	.github/scripts/pr-reviewers-trailer.py	78	CODE
LOW	.github/scripts/junit.py	144	CODE
LOW	.github/scripts/develocity_reports.py	966	CODE
LOW	.github/scripts/develocity_reports.py	226	CODE
LOW	.github/scripts/develocity_reports.py	313	CODE
LOW	.github/scripts/develocity_reports.py	415	CODE
LOW	.github/scripts/develocity_reports.py	560	CODE
LOW	.github/scripts/develocity_reports.py	603	CODE
LOW	.github/scripts/develocity_reports.py	740	CODE
LOW	.github/scripts/develocity_reports.py	845	CODE
LOW	committer-tools/refresh_collaborators.py	78	CODE

Self-Referential Comments9 hits · 23 pts

Severity	File	Line	Snippet	Context
MEDIUM	docker/generate_kafka_pr_template.py	69	# This file is generated via https://github.com/apache/kafka/blob/{file_commit(os.path.join(current_dir, self))}/docker/	COMMENT
MEDIUM	tests/setup.cfg	18	# This file defines naming convention and root search directory for autodiscovery of	COMMENT
MEDIUM	tests/kafkatest/tests/produce_consume_validate.py	22	"""This class provides a shared template for tests which follow the common pattern of:	STRING
MEDIUM	tests/kafkatest/tests/end_to_end.py	27	"""This class provides a shared template for tests which follow the common pattern of:	STRING
MEDIUM	tests/kafkatest/tests/core/snapshot_test.py	131	# Create a new topic	COMMENT
MEDIUM	tests/kafkatest/tests/core/snapshot_test.py	197	# Create a topic where the affected broker must be the leader	COMMENT
MEDIUM	…kafkatest/tests/streams/templates/log4j2_template.yaml	16	# Define the root logger with appender file	COMMENT
MEDIUM	tests/kafkatest/services/streams.py	221	# Create a randomized state directory path to prevent test interference	COMMENT
MEDIUM	tests/kafkatest/services/trogdor/trogdor.py	133	# Create the configuration file on the node.	COMMENT

Synthetic Comment Markers2 hits · 15 pts

Severity	File	Line	Snippet	Context
HIGH	…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	278	// Offset commit as requested when pausing; No records returned by consumer.poll()	COMMENT
HIGH	…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	322	// Offset commit as requested when pausing; No records returned by consumer.poll()	COMMENT

AI Structural Patterns13 hits · 12 pts

Severity	File	Line	Context
LOW	tests/kafkatest/benchmarks/core/benchmark_test.py	73	CODE
LOW	tests/kafkatest/benchmarks/core/benchmark_test.py	168	CODE
LOW	tests/kafkatest/benchmarks/core/benchmark_test.py	203	CODE
LOW	tests/kafkatest/benchmarks/core/benchmark_test.py	319	CODE
LOW	tests/kafkatest/benchmarks/core/benchmark_test.py	362	CODE
LOW	tests/kafkatest/services/console_consumer.py	61	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	44	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	239	CODE
LOW	tests/kafkatest/services/console_share_consumer.py	60	CODE
LOW	tests/kafkatest/services/verifiable_producer.py	58	CODE
LOW	tests/kafkatest/services/verifiable_share_consumer.py	120	CODE
LOW	tests/kafkatest/services/security/security_config.py	147	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	194	CODE

Fake / Example Data9 hits · 9 pts

Severity	File	Line	Snippet	Context
LOW	…er/internals/OAuthBearerClientInitialResponseTest.java	102	assertEquals("user@example.com", response.authorizationId());	CODE
LOW	…er/internals/OAuthBearerClientInitialResponseTest.java	114	assertEquals("user@example.com", response.authorizationId());	CODE
LOW	…er/internals/OAuthBearerClientInitialResponseTest.java	125	assertEquals("user@example.com", response.authorizationId());	CODE
LOW	…rocessor/internals/GlobalProcessorContextImplTest.java	68	when(streamsConfig.getString(StreamsConfig.APPLICATION_ID_CONFIG)).thenReturn("dummy-id");	CODE
LOW	…/state/internals/LeftOrRightValueDeserializerTest.java	44	when(mockDeserializer.deserialize(topic, headers, value.getBytes())).thenReturn("dummy-value");	CODE
LOW	release/test_gh_actions.py	344	_fn_namespace['preferences'].get = MagicMock(return_value="fake-token")	CODE
LOW	release/test_gh_actions.py	347	_fn_namespace['prompt'] = MagicMock(return_value="fake-token")	CODE
LOW	…pache/kafka/connect/file/FileStreamSourceTaskTest.java	132	"Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy	CODE
LOW	…pache/kafka/connect/file/FileStreamSourceTaskTest.java	132	"Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy	CODE

Redundant / Tautological Comments5 hits · 8 pts

Severity	File	Line	Snippet	Context
LOW	tests/kafkatest/tests/core/snapshot_test.py	117	# Check if the first log segment is cleaned up	COMMENT
LOW	.github/workflows/build.yml	167	# Check if there are any empty files under ./site-docs/generated, If any empty files are found, print an error	COMMENT
LOW⚡	.github/scripts/develocity_reports.py	130	# Check if running in GitHub Actions	COMMENT
LOW	.github/scripts/develocity_reports.py	728	# Check if there's a significant increase in flakiness	COMMENT
LOW	.github/scripts/develocity_reports.py	766	# Check if the test meets clearing criteria at class level	COMMENT

Slop Phrases3 hits · 8 pts

Severity	File	Line	Snippet	Context
MEDIUM	…a/org/apache/kafka/clients/producer/KafkaProducer.java	115	* Here is a simple example of using the producer to send records with strings containing sequential numbers as the key/	COMMENT
MEDIUM	…rc/main/java/org/apache/kafka/clients/admin/Admin.java	78	* Here is a simple example of using an Admin client instance to create a new topic:	COMMENT
LOW	.github/workflows/build.yml	186	# If we change these, make sure to adjust ci-complete.yml	COMMENT

AI Response Leakage1 hit · 5 pts

Severity	File	Line	Snippet	Context
HIGH	docs/streams/developer-guide/dsl-api.md	1938	Streams and tables can also be joined. Many stream processing applications in practice are coded as streaming joins. For	CODE

Modern Structural Boilerplate2 hits · 2 pts

Severity	File	Line	Snippet	Context
LOW	.github/scripts/develocity_reports.py	31	logger = logging.getLogger(__name__)	CODE
LOW	committer-tools/refresh_collaborators.py	106	def update_local_yaml_content(yaml_file_path: str, collaborators: List[str]) -> None:	CODE

TODO Padding1 hit · 2 pts

Severity	File	Line	Snippet	Context
LOW	…streams/processor/internals/TaskExecutionMetadata.java	38	// TODO: implement exponential backoff, for now we just wait 5s	COMMENT

apache/kafka

Open-Source Code Quality, Security and Technical Debt Review