2.0

Adjusted Signal

2.0

Raw Pattern Score

100%

Time Factor

2026-10-30

Last Push

10.9K

Stars

Java

Language

1.7M

Lines of Code

7.5K

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? 1303 finding(s).

Hallucinated Dependency & Supply Chain Risk 4.3/100 · LOW

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

Agent Over-Engineering Ratio 2.0/100 · LOW

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

PR Review Velocity Impact 9.2/100 · LOW

Which changes need focused human review? 1653 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 126HIGH 58MEDIUM 51LOW 1418

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 1653 distinct pattern matches across 20 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 Indicators126 hits · 1345 pts

Severity	File	Line	Snippet	Context
CRITICAL⚡	…g/apache/kafka/clients/producer/KafkaProducerTest.java	615	props.setProperty(ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, org.apache.kafka.test.MockProducerInterceptor.c	CODE
CRITICAL⚡	…g/apache/kafka/clients/producer/KafkaProducerTest.java	616	+ org.apache.kafka.test.MockProducerInterceptor.class.getName() + ", "	CODE
CRITICAL⚡	…g/apache/kafka/clients/producer/KafkaProducerTest.java	617	+ org.apache.kafka.test.MockProducerInterceptor.class.getName());	CODE
CRITICAL	…g/apache/kafka/clients/admin/KafkaAdminClientTest.java	711	new org.apache.kafka.common.feature.SupportedVersionRange(versionRange.minVersion(),	CODE
CRITICAL	…lients/consumer/internals/ShareCompletedFetchTest.java	226	assertArrayEquals("key".getBytes(), org.apache.kafka.common.utils.Utils.toNullableArray(thrown.keyBuffer	CODE
CRITICAL	…ache/kafka/common/record/UnalignedFileRecordsTest.java	55	org.apache.kafka.common.requests.ByteBufferChannel channel = new org.apache.kafka.common.requests.ByteBufferChan	CODE
CRITICAL	…va/org/apache/kafka/clients/producer/MockProducer.java	128	this(Cluster.empty(), autoComplete, new org.apache.kafka.clients.producer.internals.DefaultPartitioner(), keySer	CODE
CRITICAL	…va/org/apache/kafka/clients/producer/MockProducer.java	141	this(cluster, autoComplete, new org.apache.kafka.clients.producer.internals.DefaultPartitioner(), keySerializer,	CODE
CRITICAL	…a/org/apache/kafka/clients/admin/KafkaAdminClient.java	4472	return new ScramFormatter(org.apache.kafka.common.security.scram.internals.ScramMechanism.forMechanismName(publi	CODE
CRITICAL	…rg/apache/kafka/tools/TopicCommandIntegrationTest.java	143	testTopicName = String.format("%s-%s", info.getTestMethod().get().getName(), org.apache.kafka.test.TestUtils.ran	CODE
CRITICAL	…c/test/java/org/apache/kafka/tools/ToolsTestUtils.java	210	return org.apache.kafka.test.TestUtils.tempFile(sb.toString());	CODE
CRITICAL	…/java/kafka/test/junit/ZkClusterInvocationContext.java	231	org.apache.kafka.test.TestUtils.waitForCondition(() -> {	CODE
CRITICAL	core/src/test/java/kafka/admin/AclCommandTest.java	705	org.apache.kafka.common.utils.Exit.setExitProcedure((status, __) -> {	CODE
CRITICAL	core/src/test/java/kafka/admin/AclCommandTest.java	713	org.apache.kafka.common.utils.Exit.resetExitProcedure();	CODE
CRITICAL	…c/test/java/kafka/automq/zerozone/RouterOutV2Test.java	316	long deadlineNanos = System.nanoTime() + java.util.concurrent.TimeUnit.SECONDS.toNanos(5);	CODE
CRITICAL	…afka/automq/table/binder/AvroRecordBinderTypeTest.java	676	org.junit.jupiter.api.Assertions.fail("Expected UnsupportedOperationException for non-optional union {null,	CODE
CRITICAL	…afka/automq/table/binder/AvroRecordBinderTypeTest.java	703	org.junit.jupiter.api.Assertions.fail("Expected UnsupportedOperationException for non-optional union {null,	CODE
CRITICAL	…afka/automq/table/binder/AvroRecordBinderTypeTest.java	726	org.junit.jupiter.api.Assertions.fail("Expected UnsupportedOperationException for field with non-optional un	CODE
CRITICAL	…a/automq/table/process/RecordProcessorFactoryTest.java	880	return schemaRegistryClient.register(subject, new io.confluent.kafka.schemaregistry.avro.AvroSchema(schema));	CODE
CRITICAL	…process/convert/ProtobufRegistryConverterUnitTest.java	697	org.apache.kafka.common.utils.ByteUtils.writeVarint(indexes.length, buffer);	STRING
CRITICAL	…process/convert/ProtobufRegistryConverterUnitTest.java	699	org.apache.kafka.common.utils.ByteUtils.writeVarint(index, buffer);	STRING
CRITICAL	…mq/table/process/convert/ProtoToAvroConverterTest.java	166	com.squareup.wire.schema.internal.parser.ProtoParser.Companion.parse(ProtoConstants.DEFAULT_LOCATION, proto)	STRING
CRITICAL	…e/src/test/scala/unit/kafka/zk/KafkaZkClientTest.scala	1363	val token = new org.apache.kafka.common.security.token.delegation.DelegationToken(tokenInfo, bytes)	CODE
CRITICAL	…/coordinator/transaction/TransactionMetadataTest.scala	470	val clientTransactionState = org.apache.kafka.clients.admin.TransactionState.parse(state.name)	CODE
CRITICAL	…kafka/coordinator/group/GroupMetadataManagerTest.scala	3095	val record = new org.apache.kafka.coordinator.group.generated.GroupMetadataKey()	CODE
CRITICAL	…kafka/coordinator/group/GroupMetadataManagerTest.scala	3118	val unknownKey = new org.apache.kafka.coordinator.group.generated.GroupMetadataKey()	CODE
CRITICAL	…tegration/MetricsDuringTopicCreationDeletionTest.scala	62	val metricName = KafkaYammerMetrics.defaultRegistry.allMetrics.asScala.keys.find(_.getName.endsWith(m))	CODE
CRITICAL	…rc/test/scala/unit/kafka/admin/AddPartitionsTest.scala	151	val partitions = response.topicMetadata.asScala.head.partitionMetadata.asScala.sortBy(_.partition)	CODE
CRITICAL	…/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala	470	assertEquals(new org.apache.kafka.server.common.TopicIdPartition(topicId, t1p0.partition()), topicIdPartitionCapture	CODE
CRITICAL	…ala/unit/kafka/server/BrokerLifecycleManagerTest.scala	92	assertEquals(10L, context.mockChannelManager.unsentQueue.getFirst.request.build().asInstanceOf[BrokerRegistrationR	CODE
CRITICAL	…unit/kafka/server/ThrottledChannelExpirationTest.scala	33	private val metrics = new org.apache.kafka.common.metrics.Metrics(new MetricConfig(),	CODE
CRITICAL	…test/scala/unit/kafka/server/MetadataRequestTest.scala	385	val brokersSorted = response.get.brokers.asScala.toSeq.sortBy(_.id)	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	5199	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	5200	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	5245	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),	CODE
CRITICAL	…/test/scala/unit/kafka/server/ReplicaManagerTest.scala	5246	new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1591	assertEquals(topicIdAfterCreate, servers.head.kafkaController.controllerContext.topicIds.get(tp.topic),	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1597	assertEquals(topicIdAfterCreate, servers.head.kafkaController.controllerContext.topicIds.get(tp.topic),	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1601	TestUtils.waitUntilTrue(() => servers.head.kafkaController.controllerContext.topicIds.get(tp.topic).isEmpty,	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1617	assertEquals(topicIdAfterCreate, servers.head.kafkaController.controllerContext.topicIds.get(tp.topic),	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1623	assertEquals(topicIdAfterCreate, servers.head.kafkaController.controllerContext.topicIds.get(tp.topic),	CODE
CRITICAL⚡	…/unit/kafka/controller/ControllerIntegrationTest.scala	1627	TestUtils.waitUntilTrue(() => !servers.head.kafkaController.controllerContext.allTopics.contains(tp.topic),	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1722	TestUtils.waitUntilTrue(() => !servers.head.kafkaController.controllerContext.allTopics.contains(tp.topic),	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1777	TestUtils.waitUntilTrue(() => !servers.head.kafkaController.controllerContext.allTopics.contains(tp.topic),	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1794	val id = servers.head.kafkaController.controllerContext.topicIds.get(tp.topic)	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1807	val topicIdOpt = servers.head.kafkaController.controllerContext.topicIds.get(tp.topic)	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1809	val topicNameOpt = servers.head.kafkaController.controllerContext.topicNames.get(topicId)	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1849	TestUtils.waitUntilTrue(() => !servers.head.kafkaController.controllerContext.topicNames.contains(topicId),	CODE
CRITICAL	…/unit/kafka/controller/ControllerIntegrationTest.scala	1851	assertEquals(None, servers.head.kafkaController.controllerContext.topicIds.get(tp.topic))	CODE
CRITICAL	…t/scala/unit/kafka/log/LogCleanerIntegrationTest.scala	60	val partitionFile = log.logSegments.asScala.last.log.file()	CODE
CRITICAL	core/src/test/scala/unit/kafka/log/LogCleanerTest.scala	1752	log.logSegments.asScala.head.log.renameTo(new File(Utils.replaceSuffix(log.logSegments.asScala.head.log.file.getPath	CODE
CRITICAL	core/src/test/scala/unit/kafka/log/LogCleanerTest.scala	1807	log.logSegments.asScala.head.timeIndex.file.renameTo(new File(Utils.replaceSuffix(log.logSegments.asScala.head.timeI	CODE
CRITICAL	core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala	2673	val segmentLastOffsetOpt = segmentFetchInfo.records.records.asScala.lastOption.map(_.offset)	CODE
CRITICAL	core/src/test/scala/unit/kafka/log/LogManagerTest.scala	624	val indexFilesOnDiskBeforeDelete = activeSegment.log.file.getParentFile.listFiles.filter(_.getName.endsWith("index")	CODE
CRITICAL	…/integration/kafka/zk/ZkMigrationIntegrationTest.scala	1004	val brokerEpoch = zkClusterInstance.getUnderlying.brokers.head.replicaManager.brokerEpochSupplier.apply()	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	895	val metricsFromOldTests = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.filter(isProcessorMetric)	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1186	assertEquals(2, broker.config.dynamicConfig.reconfigurables.asScala.count(r => r.isInstanceOf[DataPlaneAcceptor]))	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1189	def acceptors: Seq[DataPlaneAcceptor] = broker.config.dynamicConfig.reconfigurables.asScala.filter(_.isInstanceOf[Da	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1388	server.socketServer.metrics.metrics.keySet.asScala.exists(_.tags.get("listener") == listenerName)	CODE
CRITICAL	…on/kafka/server/DynamicBrokerReconfigurationTest.scala	1664	Thread.getAllStackTraces.keySet.asScala.toList.map(_.getName)	CODE
66 more matches not shown…

Over-Commented Block830 hits · 823 pts

Severity	File	Line	Snippet	Context
LOW	.asf.yaml	1	# Licensed to the Apache Software Foundation (ASF) under one	COMMENT
LOW	automq_release.py	1	# Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	reviewers.py	1	#!/usr/bin/env python3	COMMENT
LOW	kafka-merge-pr.py	1	#!/usr/bin/env python	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	…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	…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-12",	COMMENT
LOW	…mon/message/AutomqPreparePartitionHandoffResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…esources/common/message/GetOpeningStreamsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	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	"flexibleVersions": "0+",	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	// Version 1 and 2 are the same as version 0.	COMMENT
LOW	…in/resources/common/message/DeleteStreamsResponse.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…main/resources/common/message/DeleteGroupsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…in/resources/common/message/GetNextNodeIdResponse.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	…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	…in/resources/common/message/UpdateMetadataRequest.json	21	// Version 1 allows specifying multiple endpoints for each broker.	COMMENT
LOW	…mmon/message/AutomqPreparePartitionHandoffRequest.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	…/resources/common/message/AutomqZoneRouterRequest.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	…rc/main/resources/common/message/DeleteKVsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
LOW	…/src/main/resources/common/message/PutKVsResponse.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	…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	…esources/common/message/CommitStreamObjectRequest.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	//	COMMENT
LOW	…ts/src/main/resources/common/message/FetchRequest.json	41	// Version 8 is the same as version 7.	COMMENT
LOW	…s/common/message/GetTelemetrySubscriptionsRequest.json	1	// Licensed to the Apache Software Foundation (ASF) under one or more	COMMENT
770 more matches not shown…

Hyper-Verbose Identifiers294 hits · 300 pts

Severity	File	Line	Snippet	Context
LOW	…fka/clients/producer/internals/TransactionManager.java	1174	abstract class TxnRequestHandler implements RequestCompletionHandler {	CODE
LOW	…ka/clients/consumer/internals/ConsumerCoordinator.java	1305	private class OffsetCommitResponseHandler extends CoordinatorResponseHandler<OffsetCommitResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/ConsumerCoordinator.java	1449	private class OffsetFetchResponseHandler extends CoordinatorResponseHandler<OffsetFetchResponse, Map<TopicPartition,	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	632	private class JoinGroupResponseHandler extends CoordinatorResponseHandler<JoinGroupResponse, ByteBuffer> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	812	private class SyncGroupResponseHandler extends CoordinatorResponseHandler<SyncGroupResponse, ByteBuffer> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	914	private class FindCoordinatorResponseHandler extends RequestFutureAdapter<ClientResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1194	private class LeaveGroupResponseHandler extends CoordinatorResponseHandler<LeaveGroupResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1232	private class HeartbeatResponseHandler extends CoordinatorResponseHandler<HeartbeatResponse, Void> {	CODE
LOW	…ka/clients/consumer/internals/AbstractCoordinator.java	1286	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	34	def build_docker_image_runner(command, image_type):	CODE
LOW	docker/prepare_docker_official_image_source.py	42	def remove_args_and_hardcode_values(file_path, kafka_version, kafka_url):	CODE
LOW	docker/docker_official_image_build_test.py	45	def build_docker_official_image(image, tag, kafka_version, image_type):	CODE
LOW	…a/coordinator/AbstractCoordinatorConcurrencyTest.scala	255	def getOrCreateLogs(): mutable.Map[TopicPartition, (UnifiedLog, Long)] = {	CODE
LOW	…nit/kafka/coordinator/group/GroupCoordinatorTest.scala	4237	private def offsetAndMetadata(offset: Long): OffsetAndMetadata = {	CODE
LOW	…a/unit/kafka/coordinator/group/GroupMetadataTest.scala	861	private def offsetAndMetadata(offset: Long, timestamp: Long = Time.SYSTEM.milliseconds()): OffsetAndMetadata = {	CODE
LOW	…er/handlers/DescribeTopicPartitionsRequestHandler.java	46	public class DescribeTopicPartitionsRequestHandler {	CODE
LOW	core/src/main/scala/kafka/zk/KafkaZkClient.scala	484	def setOrCreateEntityConfigs(rootEntityType: String, sanitizedEntityName: String, config: Properties): Unit = {	CODE
LOW	core/src/main/scala/kafka/zk/KafkaZkClient.scala	1070	def setOrCreatePartitionReassignment(reassignment: collection.Map[TopicPartition, Seq[Int]], expectedControllerEpochZk	CODE
LOW	core/src/main/scala/kafka/zk/KafkaZkClient.scala	1567	def setOrCreateDelegationToken(token: DelegationToken): Unit = {	CODE
LOW	core/src/main/scala/kafka/zk/KafkaZkClient.scala	1709	def setOrCreateConsumerOffset(group: String, topicPartition: TopicPartition, offset: Long): Unit = {	CODE
LOW	core/src/main/scala/kafka/zk/KafkaZkClient.scala	1732	def getOrCreateMigrationState(initialState: ZkMigrationLeadershipState): ZkMigrationLeadershipState = {	CODE
LOW	core/src/main/scala/kafka/zk/ZkMigrationClient.scala	107	override def getOrCreateMigrationRecoveryState(	CODE
LOW	…rc/main/scala/kafka/tools/TestRaftRequestHandler.scala	33	class TestRaftRequestHandler(	CODE
LOW	…/coordinator/transaction/TransactionStateManager.scala	371	private def getAndMaybeAddTransactionState(transactionalId: String,	CODE
LOW	…n/scala/kafka/coordinator/group/GroupCoordinator.scala	1299	private def setAndPropagateAssignment(group: GroupMetadata, assignment: Map[String, Array[Byte]]): Unit = {	CODE
LOW	…n/scala/kafka/coordinator/group/GroupCoordinator.scala	1305	private def resetAndPropagateAssignmentError(group: GroupMetadata, error: Errors): Unit = {	CODE
LOW	…ala/kafka/coordinator/group/GroupMetadataManager.scala	231	def getOrMaybeCreateGroup(groupId: String, createIfNotExist: Boolean): Option[GroupMetadata] = {	CODE
LOW	core/src/main/scala/kafka/network/SocketServer.scala	1854	private def getOrCreateConnectionRateQuotaSensor(quotaLimit: Int, connectionQuotaEntity: ConnectionQuotaEntity): Senso	CODE
LOW	core/src/main/scala/kafka/network/RequestChannel.scala	793	def getOrCreateMeter(): Meter = {	CODE
LOW	…e/src/main/scala/kafka/server/ClientQuotaManager.scala	345	def getOrCreateQuotaSensors(session: Session, clientId: String): ClientSensors = {	CODE
LOW	…e/src/main/scala/kafka/server/ClientQuotaManager.scala	398	protected def getOrCreateSensor(sensorName: String, expirationTimeSeconds: Long, registerMetrics: Sensor => Unit): Sen	CODE
LOW	core/src/main/scala/kafka/server/ReplicaManager.scala	2710	private[kafka] def getOrCreatePartition(tp: TopicPartition,	CODE
LOW	…re/src/main/scala/kafka/server/ForwardingManager.scala	119	class ForwardingResponseHandler extends ControllerRequestCompletionHandler {	CODE
LOW	core/src/main/scala/kafka/server/SensorAccess.scala	31	def getOrCreate(sensorName: String, expirationTime: Long, registerMetrics: Sensor => Unit): Sensor = {	CODE
LOW	…/src/main/scala/kafka/server/KafkaRequestHandler.scala	93	class KafkaRequestHandler(	CODE
LOW	…c/main/scala/kafka/server/BrokerLifecycleManager.scala	415	private class BrokerRegistrationResponseHandler extends ControllerRequestCompletionHandler {	CODE
LOW	…c/main/scala/kafka/server/BrokerLifecycleManager.scala	487	private class BrokerHeartbeatResponseHandler(currentOfflineDirs: Iterable[Uuid]) extends ControllerRequestCompletionHa	CODE
LOW	core/src/main/scala/kafka/server/KafkaServer.scala	755	private def getOrGenerateClusterId(zkClient: KafkaZkClient): String = {	CODE
LOW	core/src/main/scala/kafka/server/KafkaServer.scala	1130	private def getOrGenerateBrokerId(metaPropsEnsemble: MetaPropertiesEnsemble): Int = {	CODE
LOW	…rc/main/scala/kafka/server/AbstractFetcherThread.scala	894	def getAndMaybePut(topicPartition: TopicPartition): FetcherLagMetrics = {	CODE
LOW	core/src/main/scala/kafka/server/ConfigHandler.scala	253	def getOrDefault(prop: String): Long = updatedDynamicBrokerConfigs get prop match {	CODE
LOW	…scala/kafka/server/ControllerRegistrationManager.scala	238	private class RegistrationResponseHandler extends ControllerRequestCompletionHandler {	CODE
LOW	…ala/kafka/server/streamaspect/BrokerQuotaManager.scala	260	private def getOrCreateQuotaSensors(quotaType: QuotaType): ClientSensors = {	CODE
LOW	…ala/kafka/server/streamaspect/BrokerQuotaManager.scala	283	override def getOrCreateQuotaSensors(session: Session,	CODE
LOW	…/kafka/server/streamaspect/ElasticReplicaManager.scala	1015	private[kafka] def getOrCreatePartitionV2(	CODE
LOW	core/src/main/scala/kafka/utils/Pool.scala	46	def getAndMaybePut(key: K): V = {	CODE
LOW	core/src/main/scala/kafka/utils/Pool.scala	61	def getAndMaybePut(key: K, createValue: => V): V =	CODE
LOW	core/src/main/scala/kafka/raft/KafkaMetadataLog.scala	109	private def handleAndConvertLogAppendInfo(appendInfo: internals.log.LogAppendInfo): LogAppendInfo = {	CODE
LOW	core/src/main/scala/kafka/log/LogManager.scala	1084	def getOrCreateLog(topicPartition: TopicPartition, isNew: Boolean = false, isFuture: Boolean = false,	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 consumer_supports_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	80	def acl_command_supports_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	83	def topic_command_supports_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	86	def topic_command_supports_if_not_exists_with_bootstrap_server(self):	CODE
LOW⚡	tests/kafkatest/version.py	89	def supports_tls_to_zookeeper(self):	CODE
LOW⚡	tests/kafkatest/version.py	93	def reassign_partitions_command_supports_bootstrap_server(self):	CODE
234 more matches not shown…

Cross-File Repetition35 hits · 175 pts

Severity	File	Snippet	Context
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/client/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/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	…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	tests/kafkatest/tests/client/quota_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	tests/kafkatest/tests/core/log_dir_failure_test.py	discover node of requested type. for leader type, discovers leader for our topic and partition 0	STRING
HIGH	tests/kafkatest/tests/core/replication_test.py	discover node of requested type. for leader type, discovers leader for our topic and partition 0	STRING
HIGH	…/kafkatest/tests/streams/streams_broker_bounce_test.py	discover node of requested type. for leader type, discovers leader for our topic and partition 0	STRING
HIGH	tests/kafkatest/automq/s3_leakage_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/compaction_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/memory_occupancy_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/__init__.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/archive_e2e_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/automq_e2e_util.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/version_upgrade_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	STRING
HIGH	tests/kafkatest/automq/quota_test.py	copyright 2025, automq hk limited. licensed under apache-2.0.	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

Excessive Try-Catch Wrapping68 hits · 80 pts

Severity	File	Line	Snippet	Context
LOW	kafka-merge-pr.py	142	except Exception as error:	CODE
LOW	kafka-merge-pr.py	202	except Exception as error:	CODE
LOW	kafka-merge-pr.py	225	except Exception as error:	CODE
LOW	kafka-merge-pr.py	236	except Exception as error:	CODE
LOW	kafka-merge-pr.py	274	except Exception as error:	CODE
MEDIUM	kafka-merge-pr.py	77	def get_json(url):	CODE
LOW⚡	docker/test/docker_sanity_test.py	179	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	184	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	189	except Exception as e:	CODE
LOW⚡	docker/test/docker_sanity_test.py	194	except Exception as e:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	104	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	140	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	187	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	202	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	212	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	240	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	291	except Exception:	CODE
MEDIUM	tests/kafkatest/tests/core/automq_tabletopic_base.py	100	def _ok(self, url, expected_status):	CODE
LOW	…st/tests/core/automq_tabletopic_broker_restart_test.py	50	except Exception as e:	CODE
LOW⚡	tests/kafkatest/tests/core/automq_remote_write_test.py	109	except Exception:	CODE
LOW⚡	tests/kafkatest/tests/core/automq_remote_write_test.py	123	except Exception as e:	CODE
LOW⚡	tests/kafkatest/tests/core/automq_remote_write_test.py	186	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_remote_write_test.py	94	except Exception as e:	CODE
LOW	tests/kafkatest/tests/core/automq_remote_write_test.py	148	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_remote_write_test.py	241	except Exception as e:	CODE
LOW	tests/kafkatest/tests/core/automq_remote_write_test.py	294	except Exception as e:	CODE
LOW	tests/kafkatest/tests/core/automq_remote_write_test.py	347	except Exception as e:	CODE
LOW⚡	tests/kafkatest/tests/core/automq_telemetry_test.py	96	except Exception as e:	CODE
LOW⚡	tests/kafkatest/tests/core/automq_telemetry_test.py	104	except Exception:	CODE
LOW	tests/kafkatest/tests/core/automq_telemetry_test.py	154	except Exception:	CODE
MEDIUM	tests/kafkatest/tests/core/automq_telemetry_test.py	99	def _metrics_ready(self, node, port):	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	124	except Exception:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	149	except Exception:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	187	except Exception:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	216	except Exception as e:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	291	except Exception as e:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	357	except Exception as e:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	420	except Exception as e:	CODE
LOW	…s/kafkatest/tests/connect/connect_remote_write_test.py	468	except Exception as e:	CODE
LOW⚡	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	461	except Exception as e:	CODE
LOW⚡	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	479	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	147	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	339	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	345	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	378	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	685	except Exception as e:	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	763	except Exception as e:	CODE
LOW	…est/tests/client/client_compatibility_features_test.py	62	except Exception as e:	CODE
LOW	…est/tests/client/client_compatibility_features_test.py	115	except Exception as e:	CODE
LOW	tests/kafkatest/services/streams.py	233	except Exception as exception:	CODE
MEDIUM	tests/kafkatest/services/streams.py	229	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
MEDIUM	tests/kafkatest/services/kafka/kafka.py	669	def start(self, add_principals="", nodes_to_skip=[], timeout_sec=60, **kwargs):	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	760	except Exception:	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	765	except Exception:	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	1050	except Exception:	CODE
LOW	…s/kafkatest/services/performance/automq_performance.py	182	except Exception:	CODE
LOW⚡	…s/kafkatest/services/performance/automq_performance.py	210	except Exception:	CODE
LOW⚡	…s/kafkatest/services/performance/automq_performance.py	212	except Exception:	CODE
8 more matches not shown…

Unused Imports81 hits · 78 pts

Severity	File	Line	Context
LOW	docker/generate_kafka_pr_template.py	36	CODE
LOW	tests/report_e2e_results.py	21	CODE
LOW	…ts/kafkatest/sanity_checks/test_verifiable_producer.py	26	CODE
LOW	…ts/kafkatest/sanity_checks/test_verifiable_producer.py	26	CODE
LOW	…s/kafkatest/sanity_checks/test_performance_services.py	16	CODE
LOW	…s/kafkatest/sanity_checks/test_performance_services.py	24	CODE
LOW	…s/kafkatest/sanity_checks/test_performance_services.py	24	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	31	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/replication_test.py	19	CODE
LOW	…/tests/core/automq_tabletopic_schema_evolution_test.py	17	CODE
LOW	…atest/tests/core/compatibility_test_new_broker_test.py	13	CODE
LOW	…atest/tests/core/compatibility_test_new_broker_test.py	24	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	20	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	20	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	21	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	21	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	22	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	24	CODE
LOW	…kafkatest/tests/core/controller_mutation_quota_test.py	27	CODE
LOW	tests/kafkatest/tests/core/upgrade_test.py	27	CODE
LOW	tests/kafkatest/tests/core/snapshot_test.py	16	CODE
LOW	tests/kafkatest/tests/core/kraft_upgrade_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/core/automq_telemetry_test.py	20	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	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	19	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	19	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	22	CODE
LOW	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	16	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	27	CODE
LOW	…afkatest/tests/client/consumer_rolling_upgrade_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
21 more matches not shown…

Empty Error Handlers14 hits · 70 pts

Severity	File	Line	Snippet	Context
HIGH	tests/kafkatest/tests/core/security_test.py	206	except TimeoutError:	CODE
HIGH	tests/kafkatest/tests/core/security_test.py	137	except TimeoutError:	CODE
HIGH	tests/kafkatest/tests/core/automq_tabletopic_base.py	291	except Exception:	CODE
HIGH	tests/kafkatest/tests/core/automq_tabletopic_base.py	140	except Exception:	CODE
HIGH	tests/kafkatest/tests/core/automq_tabletopic_base.py	240	except Exception:	CODE
HIGH	tests/kafkatest/tests/core/automq_remote_write_test.py	186	except Exception:	CODE
HIGH	…s/kafkatest/tests/connect/connect_remote_write_test.py	187	except Exception:	CODE
HIGH	tests/kafkatest/tests/connect/connect_rest_test.py	133	except ConnectRestError:	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	760	except Exception:	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	765	except Exception:	CODE
HIGH	…kafkatest/services/performance/producer_performance.py	151	except:	CODE
HIGH	…s/kafkatest/services/performance/automq_performance.py	182	except Exception:	CODE
HIGH	…s/kafkatest/services/performance/automq_performance.py	212	except Exception:	CODE
HIGH	…s/kafkatest/services/performance/automq_performance.py	225	except Exception:	CODE

Verbosity Indicators40 hits · 69 pts

Severity	File	Line	Snippet	Context
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1667	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1676	// Step 5: receive an empty assignment, which means we should call revoke	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1684	// Step 6: revoke partitions	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1694	// Step 7: assign partitions should still be called, even though it's empty	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1704	// Step 8: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	2047	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	2056	// Step 3: invoke the callback	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1641	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1656	// Step 3: assign partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1716	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1732	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1747	// Step 3: revoke partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1759	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1770	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1785	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1800	// Step 3: revoke partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1811	// Step 4: assign partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1823	// Step 5: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	2032	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	2067	// Step 4: Receive ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1593	// Step 1: Send client requests.	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1604	// 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	1614	// 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	1621	// Step 4: Process buffered data. if `responseRequiredIndex>=0`, the channel should be failed and removed when	COMMENT
LOW	…che/kafka/coordinator/group/OffsetMetadataManager.java	501	// Step 1: If force and group is non-empty, fence all members.	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	190	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	203	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	208	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	227	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	243	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	248	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	127	# Step 1: run migration tool	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	129	# Step 2: restart brokers with zookeeper.set.acl=true and acls (with TLS but no SASL)	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	137	# Step 1: remove ACLs created previously	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	141	# Step 2: enable ZooKeeper SASL authentication, but don't take advantage of it in Kafka yet	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	148	# Step 3: run migration tool	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	150	# Step 4: restart brokers with zookeeper.set.acl=true and acls (with both TLS and SASL)	COMMENT
LOW⚡	…sts/kafkatest/tests/core/automq_tabletopic_e2e_test.py	77	# Step 1: Produce Avro messages via AutoMQPerformanceService (random Avro if no values-file)	COMMENT
LOW⚡	…sts/kafkatest/tests/core/automq_tabletopic_e2e_test.py	80	# Step 2: Verify table exists and contains expected data (polling for commit interval)	COMMENT
LOW	…/org/apache/kafka/connect/runtime/rest/RestServer.java	241	// TODO: we need to check if these listeners are same as 'listeners'	COMMENT

Structural Annotation Overuse39 hits · 68 pts

Severity	File	Line	Snippet	Context
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1667	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1676	// Step 5: receive an empty assignment, which means we should call revoke	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1684	// Step 6: revoke partitions	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1694	// Step 7: assign partitions should still be called, even though it's empty	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	1704	// Step 8: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	2047	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW⚡	…ents/consumer/internals/MembershipManagerImplTest.java	2056	// Step 3: invoke the callback	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1641	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1656	// Step 3: assign partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1716	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1732	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1747	// Step 3: revoke partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1759	// Step 4: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1770	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1785	// Step 2: put the state machine into the appropriate... state	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1800	// Step 3: revoke partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1811	// Step 4: assign partitions	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	1823	// Step 5: Send ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	2032	// Step 1: set up mocks	COMMENT
LOW	…ents/consumer/internals/MembershipManagerImplTest.java	2067	// Step 4: Receive ack and make sure we're done and our listener was called appropriately	COMMENT
LOW	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1593	// Step 1: Send client requests.	COMMENT
LOW⚡	…c/test/scala/unit/kafka/network/SocketServerTest.scala	1604	// 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	1614	// 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	1621	// Step 4: Process buffered data. if `responseRequiredIndex>=0`, the channel should be failed and removed when	COMMENT
LOW	…che/kafka/coordinator/group/OffsetMetadataManager.java	501	// Step 1: If force and group is non-empty, fence all members.	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	190	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	203	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	208	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW	…/streams/integration/InternalTopicIntegrationTest.java	227	// Step 1: Configure and start a simple word count topology	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	243	// Step 2: Produce some input data to the input topic.	COMMENT
LOW⚡	…/streams/integration/InternalTopicIntegrationTest.java	248	// Step 3: Verify the state changelog topics are compact	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	127	# Step 1: run migration tool	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	129	# Step 2: restart brokers with zookeeper.set.acl=true and acls (with TLS but no SASL)	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	137	# Step 1: remove ACLs created previously	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	141	# Step 2: enable ZooKeeper SASL authentication, but don't take advantage of it in Kafka yet	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	148	# Step 3: run migration tool	COMMENT
LOW⚡	tests/kafkatest/tests/core/zookeeper_tls_test.py	150	# Step 4: restart brokers with zookeeper.set.acl=true and acls (with both TLS and SASL)	COMMENT
LOW⚡	…sts/kafkatest/tests/core/automq_tabletopic_e2e_test.py	77	# Step 1: Produce Avro messages via AutoMQPerformanceService (random Avro if no values-file)	COMMENT
LOW⚡	…sts/kafkatest/tests/core/automq_tabletopic_e2e_test.py	80	# Step 2: Verify table exists and contains expected data (polling for commit interval)	COMMENT

AI Slop Vocabulary18 hits · 42 pts

Severity	File	Line	Snippet	Context
MEDIUM	…a/org/apache/kafka/clients/producer/KafkaProducer.java	739	* {@link KafkaConsumer#groupMetadata()} to leverage consumer group metadata. This will provide	COMMENT
LOW	…a/org/apache/kafka/clients/consumer/KafkaConsumer.java	294	* 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	627	* 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	…n/scala/kafka/coordinator/group/GroupCoordinator.scala	1451	// skip running the assignor based on the `SkipAssignment` field. We leverage	COMMENT
MEDIUM	…/src/main/scala/kafka/controller/KafkaController.scala	2722	// handleDeletion(). This approach is more robust as it doesn't depend on the watcher being re-registered after	COMMENT
LOW	vagrant/base.sh	170	# 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	131	// 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	243	# To check ordering, we simply create input and output topics	COMMENT
MEDIUM	tests/kafkatest/tests/core/reassign_partitions_test.py	147	# latter is more robust.	COMMENT
MEDIUM	…/kafkatest/tests/streams/streams_broker_bounce_test.py	172	# Start test harness	COMMENT
MEDIUM	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	214	# Print ALL metrics for comprehensive debugging	COMMENT
MEDIUM⚡	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	195	# This is more robust than trying to parse the exact table format	STRING
MEDIUM	tests/kafkatest/services/monitor/jmx.py	75	# JmxTool is not particularly robust to slow-starting processes. In order to ensure JmxTool doesn't fail if the	COMMENT
MEDIUM	docs/streams/developer-guide/processor-api.html	232	It’s common practice to leverage an existing store type via the <code class="docutils literal"	CODE
MEDIUM	docs/streams/developer-guide/datatypes.html	82	<p>If you want to override serdes selectively, i.e., keep the defaults for some fields, then don’t specify t	CODE
MEDIUM	docs/streams/developer-guide/datatypes.html	108	<p>This artifact provides the following serde implementations under the package <a class="reference external" hr	CODE
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

Self-Referential Comments14 hits · 33 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	docker/telemetry/install.sh	15	# Define the function to stop the containers	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	132	# Create a new topic	COMMENT
MEDIUM	tests/kafkatest/tests/core/snapshot_test.py	203	# Create a topic where the affected broker must be the leader	COMMENT
MEDIUM	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	116	# Create a simple mock AzMetadataProvider implementation directly in the Connect runtime classpath	COMMENT
MEDIUM	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	158	# Create the package directory structure in the runtime classes	STRING
MEDIUM	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	169	# Create the ServiceLoader service definition in the runtime classes	STRING
MEDIUM	tests/kafkatest/services/trogdor/trogdor.py	133	# Create the configuration file on the node.	COMMENT
MEDIUM	docs/ops.html	820	<pre><code class="language-text"># Defining a custom separator	CODE
MEDIUM	…tainer/bitnami/prebuildfs/opt/bitnami/scripts/libos.sh	41	# Create a group in the system if it does not exist already	COMMENT
MEDIUM	…tainer/bitnami/prebuildfs/opt/bitnami/scripts/libos.sh	89	# Create an user in the system if it does not exist already	COMMENT

Redundant / Tautological Comments22 hits · 33 pts

Severity	File	Line	Snippet	Context
LOW	docker/telemetry/install.sh	5	# Set DATA_PATH to the current absolute path	COMMENT
LOW	tests/kafkatest/tests/core/snapshot_test.py	118	# Check if the first log segment is cleaned up	COMMENT
LOW⚡	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	469	# Check if bucket exists but is empty	COMMENT
LOW⚡	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	203	# Check if any line contains the expected AZ metadata	STRING
LOW	tests/kafkatest/services/kafka/kafka.py	1956	# Check if the cluster is in a state where we should not perform this operation	COMMENT
LOW	…ntainer/bitnami/rootfs/opt/bitnami/scripts/libkafka.sh	46	# Check if the value was set before	COMMENT
LOW	…ntainer/bitnami/rootfs/opt/bitnami/scripts/libkafka.sh	1133	# Check if Kafka is running	COMMENT
LOW	…ntainer/bitnami/rootfs/opt/bitnami/scripts/libkafka.sh	1152	# Check if Kafka is running	COMMENT
LOW	…r/bitnami/prebuildfs/opt/bitnami/scripts/libservice.sh	33	# Check if a provided PID corresponds to a running service	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libpersistence.sh	108	# Check if an application directory was already persisted	COMMENT
LOW	…ainer/bitnami/prebuildfs/opt/bitnami/scripts/libnet.sh	72	# Check if the first IP address is IPv6 to add brackets	COMMENT
LOW	…ainer/bitnami/prebuildfs/opt/bitnami/scripts/libnet.sh	81	# Check if the provided argument is a resolved hostname	COMMENT
LOW	…tainer/bitnami/prebuildfs/opt/bitnami/scripts/libos.sh	17	# Check if an user exists in the system	COMMENT
LOW	…tainer/bitnami/prebuildfs/opt/bitnami/scripts/libos.sh	29	# Check if a group exists in the system	COMMENT
LOW	…tainer/bitnami/prebuildfs/opt/bitnami/scripts/libos.sh	178	# Check if the script is currently running as root	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	15	# Check if the provided argument is an integer	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	31	# Check if the provided argument is a positive integer	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	47	# Check if the provided argument is a boolean or is the string 'yes/true'	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	65	# Check if the provided argument is a boolean yes/no value	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	81	# Check if the provided argument is a boolean true/false value	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	97	# Check if the provided argument is a boolean 1/0 value	COMMENT
LOW	…tnami/prebuildfs/opt/bitnami/scripts/libvalidations.sh	113	# Check if the provided argument is an empty string or not defined	COMMENT

Cross-Language Confusion6 hits · 30 pts

Severity	File	Line	Snippet	Context
HIGH	tests/kafkatest/tests/core/automq_remote_write_test.py	170	which_py = "PYBIN=$(command -v python3 \|\| command -v python \|\| echo python3)"	CODE
HIGH	…s/kafkatest/tests/connect/connect_remote_write_test.py	171	which_py = "PYBIN=$(command -v python3 \|\| command -v python \|\| echo python3)"	CODE
HIGH	…ts/kafkatest/tests/connect/connect_az_metadata_test.py	134	if (az == null \|\| az.isBlank()) {{	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	1505	cmd += "&& sleep 1 && rm -f %s" % json_file	CODE
HIGH	tests/kafkatest/services/kafka/kafka.py	1547	cmd += " && sleep 1 && rm -f %s" % json_file	CODE
HIGH	…s/kafkatest/services/performance/automq_performance.py	174	f"cp -f {result_file} {AutoMQPerformanceService.PERSISTENT_ROOT}/result.json \|\| true",	CODE

Decorative Section Separators8 hits · 30 pts

Severity	File	Line	Snippet	Context
MEDIUM⚡	tests/kafkatest/tests/core/automq_remote_write_test.py	193	# ------------------------------------------------------------------	COMMENT
MEDIUM⚡	tests/kafkatest/tests/core/automq_remote_write_test.py	195	# ------------------------------------------------------------------	COMMENT
MEDIUM	tests/kafkatest/tests/core/automq_remote_write_test.py	39	# ------------------------------------------------------------------	COMMENT
MEDIUM	tests/kafkatest/tests/core/automq_remote_write_test.py	41	# ------------------------------------------------------------------	COMMENT
MEDIUM	tests/kafkatest/tests/core/automq_telemetry_test.py	41	# ------------------------------------------------------------------	COMMENT
MEDIUM	tests/kafkatest/tests/core/automq_telemetry_test.py	43	# ------------------------------------------------------------------	COMMENT
MEDIUM⚡	tests/kafkatest/tests/core/automq_telemetry_test.py	169	# ------------------------------------------------------------------	COMMENT
MEDIUM⚡	tests/kafkatest/tests/core/automq_telemetry_test.py	171	# ------------------------------------------------------------------	COMMENT

Synthetic Comment Markers3 hits · 22 pts

Severity	File	Line	Snippet	Context
HIGH	…c/main/java/com/automq/stream/s3/wal/util/WALUtil.java	131	// the file exists but not the same size as requested	COMMENT
HIGH	…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	250	// Offset commit as requested when pausing; No records returned by consumer.poll()	COMMENT
HIGH	…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java	294	// Offset commit as requested when pausing; No records returned by consumer.poll()	COMMENT

Slop Phrases10 hits · 22 pts

Severity	File	Line	Snippet	Context
MEDIUM	…a/org/apache/kafka/clients/producer/KafkaProducer.java	103	* 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	75	* Here is a simple example of using an Admin client instance to create a new topic:	COMMENT
MEDIUM	docs/quickstart.html	202	However, it's worth noting that for production deployments using absolute paths is always preferable. See <a	CODE
MEDIUM	docs/ops.html	119	To view offsets, as mentioned earlier, we "describe" the consumer group like this:	CODE
LOW	docs/ops.html	776	# Don't forget to enable a flow!	COMMENT
MEDIUM	docs/design.html	261	It's worth noting that this breaks down into two problems: the durability guarantees for publishing a message and th	CODE
MEDIUM	docs/design.html	461	partitions a node hosted when that node failed. As discussed above in the section on <a href="#replication">replicat	CODE
MEDIUM	docs/security.html	35	It's worth noting that security is optional - non-secured clusters are supported, as well as a mix of authenticated,	CODE
MEDIUM	docs/connect.html	952	<p>The API documentation provides a complete reference, but here is a simple example creating a <code>Schema</code>	CODE
MEDIUM	docs/streams/developer-guide/processor-api.html	435	that of non-versioned key-value stores, you may want to adjust your	CODE

Deep Nesting24 hits · 20 pts

Severity	File	Line	Context
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	159	CODE
LOW	tests/kafkatest/tests/core/automq_tabletopic_base.py	174	CODE
LOW	tests/kafkatest/tests/core/automq_telemetry_test.py	157	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	351	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	430	CODE
LOW	tests/kafkatest/tests/streams/streams_upgrade_test.py	512	CODE
LOW	…test/tests/streams/streams_application_upgrade_test.py	232	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	256	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	383	CODE
LOW	…ts/kafkatest/tests/connect/connect_metrics_log_test.py	577	CODE
LOW	…ts/kafkatest/tests/connect/connect_distributed_test.py	605	CODE
LOW	tests/kafkatest/tests/client/quota_test.py	34	CODE
LOW	tests/kafkatest/automq/automq_zerozone_test.py	153	CODE
LOW	…sts/kafkatest/services/transactional_message_copier.py	80	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	92	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	254	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	322	CODE
LOW	tests/kafkatest/services/verifiable_producer.py	126	CODE
LOW	tests/kafkatest/services/monitor/jmx.py	108	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	202	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	648	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	1559	CODE
LOW	…s/kafkatest/services/performance/automq_performance.py	134	CODE
LOW	release/textfiles.py	55	CODE

Fake / Example Data12 hits · 12 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	…a/automq/table/process/RecordProcessorFactoryTest.java	376	.setStreet("123 Main St")	CODE
LOW	…a/automq/table/process/RecordProcessorFactoryTest.java	421	assertEquals("123 Main St", addressRecord.get("street").toString());	CODE
LOW	…a/automq/table/process/RecordProcessorFactoryTest.java	466	.setStreet("123 Main St")	CODE
LOW	…a/automq/table/process/RecordProcessorFactoryTest.java	489	assertEquals("123 Main St", addressRecord.get("street").toString());	CODE
LOW	…a/automq/table/process/RecordProcessorFactoryTest.java	503	.setStreet("123 Main St")	CODE
LOW	…a/automq/table/process/RecordProcessorFactoryTest.java	519	assertEquals("123 Main St", keyRecord.get("street").toString());	CODE
LOW	…rocessor/internals/GlobalProcessorContextImplTest.java	71	when(streamsConfig.getString(StreamsConfig.APPLICATION_ID_CONFIG)).thenReturn("dummy-id");	CODE
LOW	…pache/kafka/connect/file/FileStreamSourceTaskTest.java	136	"Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy	CODE
LOW	…pache/kafka/connect/file/FileStreamSourceTaskTest.java	136	"Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy	CODE

AI Structural Patterns8 hits · 8 pts

Severity	File	Line	Context
LOW	…sts/kafkatest/services/transactional_message_copier.py	48	CODE
LOW	tests/kafkatest/services/console_consumer.py	62	CODE
LOW	tests/kafkatest/services/mirror_maker.py	43	CODE
LOW	tests/kafkatest/services/verifiable_consumer.py	215	CODE
LOW	tests/kafkatest/services/verifiable_producer.py	59	CODE
LOW	tests/kafkatest/services/security/security_config.py	147	CODE
LOW	tests/kafkatest/services/kafka/kafka.py	202	CODE
LOW	…s/kafkatest/services/performance/automq_performance.py	40	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

AutoMQ/automq

Open-Source Code Quality, Security and Technical Debt Review