Home / apache / kafka
Repository Analysis

apache/kafka

Apache Kafka - A distributed event streaming platform

1.7 Likely human-written View on GitHub
1.7
Adjusted Score
1.7
Raw Score
100%
Time Factor
2026-05-30
Last Push
32,678
Stars
Java
Language
1,680,248
Lines of Code
6993
Files
1443
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 108HIGH 44MEDIUM 32LOW 1259

Pattern Findings

1443 matches across 15 categories. Click a row to expand file-level details.

Hallucination Indicators108 hits · 1185 pts
SeverityFileLineSnippet
CRITICAL…apache/kafka/clients/admin/StaticBrokerConfigTest.java142 // broker (see org.apache.kafka.common.test.KafkaClusterTestKit.Builder.createNodeConfig()),
CRITICAL…/kafka/clients/consumer/ShareConsumerCallbackTest.java328 throw new org.apache.kafka.common.errors.OutOfOrderSequenceException("Exception thrown in Acknowledgemen
CRITICAL…rg/apache/kafka/clients/producer/MockProducerTest.java94 new org.apache.kafka.clients.producer.RoundRobinPartitioner(),
CRITICAL…g/apache/kafka/clients/admin/KafkaAdminClientTest.java781 new org.apache.kafka.common.feature.SupportedVersionRange(versionRange.minVersion(),
CRITICAL…lients/consumer/internals/ShareCompletedFetchTest.java269 assertArrayEquals("key".getBytes(), org.apache.kafka.common.utils.Utils.toNullableArray(thrown.keyBuffer
CRITICAL…ts/consumer/internals/ApplicationEventHandlerTest.java96 org.apache.kafka.common.utils.Utils.sleep(delayMs);
CRITICAL…a/common/record/internal/UnalignedFileRecordsTest.java55 org.apache.kafka.common.requests.ByteBufferChannel channel = new org.apache.kafka.common.requests.ByteBufferChan
CRITICAL…authbearer/ClientAssertionKeycloakIntegrationTest.java134 org.junit.jupiter.api.Assumptions.assumeTrue(
CRITICAL…authbearer/ClientAssertionKeycloakIntegrationTest.java964 new org.apache.kafka.common.config.types.Password(passphrase));
CRITICAL…authbearer/ClientAssertionKeycloakIntegrationTest.java993 new org.apache.kafka.common.config.types.Password(passphrase));
CRITICAL…authbearer/ClientAssertionKeycloakIntegrationTest.java1024 new org.apache.kafka.common.config.types.Password(wrongPassphrase));
CRITICAL…a/org/apache/kafka/clients/admin/KafkaAdminClient.java4530 return new ScramFormatter(org.apache.kafka.common.security.scram.internals.ScramMechanism.forMechanismName(publi
CRITICAL…/org/apache/kafka/clients/consumer/ConsumerConfig.java378 " use <code>org.apache.kafka.clients.consumer.ShareConsumer.acknowledge()</code> to acknowledge delivery of
CRITICAL…/org/apache/kafka/clients/consumer/ConsumerConfig.java381 " <code>org.apache.kafka.clients.consumer.ShareConsumer.acknowledge()</code> to acknowledge delivery of reco
CRITICAL…c/test/java/org/apache/kafka/tools/ToolsTestUtils.java169 return org.apache.kafka.test.TestUtils.tempFile(sb.toString());
CRITICAL…rc/main/java/org/apache/kafka/tools/ConfigCommand.java385 .map(mechanismName -> new UserScramCredentialDeletion(user, org.apache.kafka.clients.admin.ScramMechanis
CRITICAL…rc/main/java/org/apache/kafka/tools/ConfigCommand.java393 org.apache.kafka.common.security.scram.internals.ScramMechanism.forMechanismName(mechanismNa
CRITICAL…rc/main/java/org/apache/kafka/tools/ConfigCommand.java397 new ScramCredentialInfo(org.apache.kafka.clients.admin.ScramMechanism.fromMechanismName(mech
CRITICAL…/main/java/org/apache/kafka/tools/DumpLogSegments.java651 if (message.apiKey() == org.apache.kafka.coordinator.group.generated.CoordinatorRecordType.GROUP_METADATA.id
CRITICAL…/coordinator/transaction/TransactionMetadataTest.scala732 val clientTransactionState = org.apache.kafka.clients.admin.TransactionState.parse(state.stateName)
CRITICAL…/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala458 assertEquals(new org.apache.kafka.server.common.TopicIdPartition(topicId, t1p0.partition()), topicIdPartitionCapture
CRITICAL…/test/scala/unit/kafka/server/DelayedProduceTest.scala51 val aggregateCountBefore = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.count(name =>
CRITICAL…/test/scala/unit/kafka/server/DelayedProduceTest.scala68 val aggregateCountAfter = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.count(name =>
CRITICAL…ala/unit/kafka/server/BrokerLifecycleManagerTest.scala98 assertEquals(10L, context.mockChannelManager.unsentQueue.getFirst.request.build().asInstanceOf[BrokerRegistrationR
CRITICAL…it/kafka/server/StreamsGroupHeartbeatRequestTest.scala771 val options = new org.apache.kafka.clients.admin.AlterConfigsOptions()
CRITICAL…it/kafka/server/StreamsGroupHeartbeatRequestTest.scala781 val options2 = new org.apache.kafka.clients.admin.AlterConfigsOptions()
CRITICAL…/test/scala/unit/kafka/server/ReplicaManagerTest.scala4426 new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),
CRITICAL…/test/scala/unit/kafka/server/ReplicaManagerTest.scala4427 new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())
CRITICAL…/test/scala/unit/kafka/server/ReplicaManagerTest.scala4472 new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition0.partition()),
CRITICAL…/test/scala/unit/kafka/server/ReplicaManagerTest.scala4473 new org.apache.kafka.server.common.TopicIdPartition(topicId, topicIdPartition1.partition())
CRITICAL…on/kafka/server/DynamicBrokerReconfigurationTest.scala892 val metricsFromOldTests = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.filter(isProcessorMetric)
CRITICAL…on/kafka/server/DynamicBrokerReconfigurationTest.scala1043 assertEquals(2, broker.config.dynamicConfig.reconfigurables.asScala.count(r => r.isInstanceOf[DataPlaneAcceptor]))
CRITICAL…on/kafka/server/DynamicBrokerReconfigurationTest.scala1046 def acceptors: Seq[DataPlaneAcceptor] = broker.config.dynamicConfig.reconfigurables.asScala.filter(_.isInstanceOf[Da
CRITICAL…on/kafka/server/DynamicBrokerReconfigurationTest.scala1347 Thread.getAllStackTraces.keySet.asScala.toList.map(_.getName)
CRITICAL…ntegration/kafka/server/GssapiAuthenticationTest.scala272 _ => org.apache.kafka.test.TestUtils.defaultApiVersionsResponse(ListenerType.BROKER)) {
CRITICAL…src/test/scala/integration/kafka/api/MetricsTest.scala221 def errorMetricCount = KafkaYammerMetrics.defaultRegistry.allMetrics.keySet.asScala.count(_.getName == "ErrorsPerSec
CRITICAL…egration/kafka/api/PlaintextAdminIntegrationTest.scala1959 val matching = client.listConsumerGroups.all.get.asScala.filter(group =>
CRITICAL…egration/kafka/api/PlaintextAdminIntegrationTest.scala2224 val matching = client.listConsumerGroups.all.get.asScala.filter(group =>
CRITICALcore/src/main/scala/kafka/cluster/Partition.scala1690 new org.apache.kafka.server.common.TopicIdPartition(topicId.getOrElse(throw new IllegalStateException("Topic id no
CRITICALcore/src/main/scala/kafka/server/KafkaApis.scala2302 val renewerList = createTokenRequest.data.renewers.asScala.toList.map(entry =>
CRITICAL…fka/coordinator/group/GroupCoordinatorServiceTest.java173 Arguments.arguments(new org.apache.kafka.common.errors.TimeoutException(), Errors.COORDINATOR_NOT_AVAILABLE.
CRITICAL…fka/coordinator/group/GroupCoordinatorServiceTest.java522 Arguments.arguments(new org.apache.kafka.common.errors.TimeoutException(), Errors.COORDINATOR_NOT_AVAILABLE.
CRITICAL…dinator/group/streams/TargetAssignmentBuilderTest.java840 org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder builder = new org.apache.kafka.coordinato
CRITICAL…ache/kafka/coordinator/group/GroupMetadataManager.java3718 StreamsGroupMember updatedMember = new org.apache.kafka.coordinator.group.streams.CurrentAssignmentBuilder(membe
CRITICAL…ache/kafka/coordinator/group/GroupMetadataManager.java4081 new org.apache.kafka.coordinator.group.streams.TargetAssignmentBuilder(
CRITICAL…ache/kafka/coordinator/group/GroupMetadataManager.java5864 streamsGroup.updateTargetAssignment(memberId, org.apache.kafka.coordinator.group.streams.TasksTuple.fromTarg
CRITICAL…s/integration/InMemoryStoreMetricsIntegrationTest.java250 props.put(StreamsConfig.STATE_DIR_CONFIG, org.apache.kafka.test.TestUtils.tempDirectory().getAbsolutePath());
CRITICAL…st/java/org/apache/kafka/streams/KafkaStreamsTest.java316 org.apache.kafka.clients.consumer.CloseOptions.groupMembershipOperation(org.apache.kafka.clients.consume
CRITICAL…st/java/org/apache/kafka/streams/KafkaStreamsTest.java319 org.apache.kafka.clients.consumer.CloseOptions.groupMembershipOperation(org.apache.kafka.clients.consume
CRITICAL…a/streams/processor/internals/StreamsProducerTest.java113 = new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray
CRITICAL…a/streams/processor/internals/StreamsProducerTest.java115 = new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray
CRITICAL…a/streams/processor/internals/RecordCollectorTest.java144 = new MockProducer<>(cluster, true, new org.apache.kafka.clients.producer.RoundRobinPartitioner(), new ByteArray
CRITICAL…a/streams/processor/internals/RecordCollectorTest.java1819 new org.apache.kafka.clients.producer.RoundRobinPartitioner(),
CRITICAL…ssor/internals/assignment/TaskAssignmentUtilsTest.java356 final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment noError = new org.apache.kafka.s
CRITICAL…ssor/internals/assignment/TaskAssignmentUtilsTest.java370 final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment missingProcessId = new org.apach
CRITICAL…ssor/internals/assignment/TaskAssignmentUtilsTest.java383 final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment unknownProcessId = new org.apach
CRITICAL…ssor/internals/assignment/TaskAssignmentUtilsTest.java398 final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment unknownTaskId = new org.apache.k
CRITICAL…ssor/internals/assignment/TaskAssignmentUtilsTest.java416 final org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment activeTaskDuplicated = new org.a
CRITICAL…ls/MeteredTimestampedKeyValueStoreWithHeadersTest.java131 lenient().when(context.recordContext()).thenReturn(new org.apache.kafka.streams.processor.internals.ProcessorRec
CRITICAL…ls/MeteredTimestampedKeyValueStoreWithHeadersTest.java132 0L, 0L, 0, "topic", new org.apache.kafka.common.header.internals.RecordHeaders()));
48 more matches not shown…
Over-Commented Block781 hits · 775 pts
SeverityFileLineSnippet
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOW…ients-integration-tests/src/test/resources/log4j2.yaml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOWclients/src/test/resources/log4j2.yaml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOW…est/resources/common/message/SimpleExampleMessage.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…st/resources/common/message/NullableStructMessage.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…test/resources/common/message/SimpleArraysMessage.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…est/resources/common/message/SimpleRecordsMessage.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/src/test/resources/common/message/AllTypeMessage.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…t/java/org/apache/kafka/clients/NetworkClientTest.java1521 updater.setNodes(Collections.singletonList(freshNode));
LOW…l/CommonNameLoggingTrustManagerFactoryWrapperTest.java81 // Self-signed
LOW…ts/src/main/resources/common/message/VoteResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ces/common/message/DescribeDelegationTokenRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…es/common/message/DescribeTopicPartitionsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…esources/common/message/BrokerRegistrationRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ain/resources/common/message/DeleteRecordsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ources/common/message/AllocateProducerIdsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…rces/common/message/CreateDelegationTokenResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…sources/common/message/ShareGroupDescribeResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…sources/common/message/ShareGroupDescribeResponse.json21 //
LOW…src/main/resources/common/message/MetadataRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…src/main/resources/common/message/MetadataRequest.json21 "validVersions": "0-13",
LOW…ces/common/message/ControllerRegistrationResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…urces/common/message/AssignReplicasToDirsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/main/resources/common/message/ShareFetchResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/main/resources/common/message/ShareFetchResponse.json21 //
LOW…/resources/common/message/ShareAcknowledgeRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…c/main/resources/common/message/HeartbeatResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/main/resources/common/message/StopReplicaRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/src/main/resources/common/message/ProduceRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/src/main/resources/common/message/ProduceRequest.json21 // Versions 0-2 were removed in Apache Kafka 4.0, version 3 is the new baseline. Due to a bug in librdkafka,
LOW…main/resources/common/message/DeleteGroupsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…urces/common/message/WriteShareGroupStateResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ces/common/message/DescribeTopicPartitionsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…s/src/main/resources/common/message/EndTxnRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…resources/common/message/AlterClientQuotasRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…in/resources/common/message/UpdateMetadataRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…rces/common/message/DeleteShareGroupStateResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…resources/common/message/UnregisterBrokerResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…n/resources/common/message/DescribeGroupsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/main/resources/common/message/LeaveGroupResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ents/src/main/resources/common/message/AbortedTxn.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ommon/message/DescribeUserScramCredentialsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…n/resources/common/message/FindCoordinatorRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…n/resources/common/message/FindCoordinatorRequest.json21 // Version 1 adds KeyType.
LOW…esources/common/message/AddPartitionsToTxnRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…esources/common/message/ShareGroupDescribeRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/resources/common/message/DescribeClusterResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ain/resources/common/message/SaslHandshakeRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…n/resources/common/message/DescribeLogDirsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ts/src/main/resources/common/message/FetchRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ts/src/main/resources/common/message/FetchRequest.json21 // Versions 0-3 were removed in Apache Kafka 4.0, Version 4 is the new baseline.
LOW…ts/src/main/resources/common/message/FetchRequest.json41 //
LOW…s/common/message/GetTelemetrySubscriptionsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…sources/common/message/AlterReplicaLogDirsRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…mmon/message/DescribeUserScramCredentialsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…in/resources/common/message/DescribeQuorumRequest.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…rces/common/message/ConsumerGroupDescribeResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…in/resources/common/message/FetchSnapshotResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…/src/main/resources/common/message/ResponseHeader.json1// Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ommon/message/AlterPartitionReassignmentsResponse.json1// Licensed to the Apache Software Foundation (ASF) under one or more
721 more matches not shown…
Hyper-Verbose Identifiers265 hits · 274 pts
SeverityFileLineSnippet
LOW…fka/clients/producer/internals/TransactionManager.java1367 abstract class TxnRequestHandler implements RequestCompletionHandler {
LOW…ka/clients/consumer/internals/ConsumerCoordinator.java1353 private class OffsetCommitResponseHandler extends CoordinatorResponseHandler<OffsetCommitResponse, Void> {
LOW…ka/clients/consumer/internals/ConsumerCoordinator.java1515 private class OffsetFetchResponseHandler extends CoordinatorResponseHandler<OffsetFetchResponse, Map<TopicPartition,
LOW…ka/clients/consumer/internals/AbstractCoordinator.java640 private class JoinGroupResponseHandler extends CoordinatorResponseHandler<JoinGroupResponse, ByteBuffer> {
LOW…ka/clients/consumer/internals/AbstractCoordinator.java820 private class SyncGroupResponseHandler extends CoordinatorResponseHandler<SyncGroupResponse, ByteBuffer> {
LOW…ka/clients/consumer/internals/AbstractCoordinator.java922 private class FindCoordinatorResponseHandler extends RequestFutureAdapter<ClientResponse, Void> {
LOW…ka/clients/consumer/internals/AbstractCoordinator.java1204 private class LeaveGroupResponseHandler extends CoordinatorResponseHandler<LeaveGroupResponse, Void> {
LOW…ka/clients/consumer/internals/AbstractCoordinator.java1242 private class HeartbeatResponseHandler extends CoordinatorResponseHandler<HeartbeatResponse, Void> {
LOW…ka/clients/consumer/internals/AbstractCoordinator.java1296 protected abstract class CoordinatorResponseHandler<R, T> extends RequestFutureAdapter<ClientResponse, T> {
LOWdocker/extract_docker_official_image_artifact.py40def set_executable_permissions(directory):
LOWdocker/common.py33def build_docker_image_runner(command, image_type, kafka_archive=None):
LOWdocker/prepare_docker_official_image_source.py41def remove_args_and_hardcode_values(file_path, kafka_version, kafka_url):
LOWdocker/docker_official_image_build_test.py44def build_docker_official_image(image, tag, kafka_version, image_type):
LOW…a/coordinator/AbstractCoordinatorConcurrencyTest.scala259 def getOrCreateLogs(): mutable.Map[TopicPartition, (UnifiedLog, Long)] = {
LOW…er/handlers/DescribeTopicPartitionsRequestHandler.java43public class DescribeTopicPartitionsRequestHandler {
LOW…rc/main/scala/kafka/tools/TestRaftRequestHandler.scala36class TestRaftRequestHandler(
LOW…/coordinator/transaction/TransactionStateManager.scala404 private def getAndMaybeAddTransactionState(transactionalId: String,
LOWcore/src/main/scala/kafka/network/SocketServer.scala1601 private def getOrCreateConnectionRateQuotaSensor(quotaLimit: Int, connectionQuotaEntity: ConnectionQuotaEntity): Senso
LOWcore/src/main/scala/kafka/server/ReplicaManager.scala2309 private[kafka] def getOrCreatePartition(tp: TopicPartition,
LOW…re/src/main/scala/kafka/server/ForwardingManager.scala111 class ForwardingResponseHandler extends ControllerRequestCompletionHandler {
LOW…/src/main/scala/kafka/server/KafkaRequestHandler.scala91class KafkaRequestHandler(
LOW…rc/main/scala/kafka/server/AbstractFetcherThread.scala952 def getAndMaybePut(topicPartition: TopicPartition): FetcherLagMetrics = {
LOWcore/src/main/scala/kafka/server/ConfigHandler.scala158 def getOrDefault(prop: String): Long = updatedDynamicBrokerConfigs get prop match {
LOWtests/unit/directory_layout/check_project_paths.py37 def check_create_path_resolver_override(self):
LOWtests/unit/directory_layout/check_project_paths.py49 def check_create_path_resolver_default(self):
LOWtests/unit/directory_layout/check_project_paths.py63 def check_versioned_source_paths(self):
LOWtests/unit/directory_layout/check_project_paths.py71 def check_node_or_version_helper(self):
LOWtests/kafkatest/version.py65 def topic_command_supports_bootstrap_server(self):
LOWtests/kafkatest/version.py68 def topic_command_supports_if_not_exists_with_bootstrap_server(self):
LOWtests/kafkatest/version.py71 def supports_tls_to_zookeeper(self):
LOWtests/kafkatest/version.py75 def reassign_partitions_command_supports_bootstrap_server(self):
LOWtests/kafkatest/version.py78 def kafka_configs_command_uses_bootstrap_server(self):
LOWtests/kafkatest/version.py82 def kafka_configs_command_uses_bootstrap_server_scram(self):
LOWtests/kafkatest/version.py86 def supports_topic_ids_when_using_zk(self):
LOWtests/kafkatest/version.py107 def supports_command_property(self):
LOWtests/kafkatest/version.py114 def supports_formatter_property(self):
LOW…ts/kafkatest/sanity_checks/test_verifiable_producer.py84 def test_multiple_kraft_security_protocols(
LOW…ts/kafkatest/sanity_checks/test_verifiable_producer.py125 def test_multiple_kraft_sasl_mechanisms(self, metadata_quorum):
LOWtests/kafkatest/tests/verifiable_share_consumer_test.py76 def await_consumed_messages_by_a_consumer(self, consumer, node, min_messages=1, timeout_sec=10, total=False):
LOWtests/kafkatest/tests/verifiable_share_consumer_test.py84 def await_unique_consumed_messages(self, consumer, min_messages=1, timeout_sec=10):
LOWtests/kafkatest/tests/verifiable_share_consumer_test.py89 def await_acknowledged_messages(self, consumer, min_messages=1, timeout_sec=10):
LOWtests/kafkatest/tests/verifiable_share_consumer_test.py94 def await_unique_acknowledged_messages(self, consumer, min_messages=1, timeout_sec=10):
LOWtests/kafkatest/tests/produce_consume_validate.py51 def start_producer_and_consumer(self):
LOWtests/kafkatest/tests/produce_consume_validate.py93 def stop_producer_and_consumer(self):
LOWtests/kafkatest/tests/produce_consume_validate.py99 def run_produce_consume_validate(self, core_test_action=None, *args):
LOWtests/kafkatest/tests/end_to_end.py45 def create_zookeeper_if_necessary(self, num_nodes=1, **kwargs):
LOWtests/kafkatest/tests/verifiable_consumer_test.py89 def await_all_members_stabilized(self, topic, num_partitions, consumer, timeout_sec):
LOWtests/kafkatest/tests/tools/log_compaction_test.py52 def start_test_log_compaction_tool(self, security_protocol, compression_config={}):
LOWtests/kafkatest/tests/tools/trogdor_test.py72 def test_network_partition_fault(self):
LOW…sts/kafkatest/tests/tools/replica_verification_test.py60 def start_replica_verification_tool(self, security_protocol):
LOWtests/kafkatest/tests/core/fetch_from_follower_test.py73 def test_consumer_preferred_read_replica(self, metadata_quorum, group_protocol=None):
LOWtests/kafkatest/tests/core/transactions_test.py141 def copy_messages_transactionally(self, failure_mode, bounce_target,
LOW…fkatest/tests/core/transactions_mixed_versions_test.py115 def copy_messages_transactionally(self, input_topic, output_topic,
LOW…fkatest/tests/core/transactions_mixed_versions_test.py198 def test_transactions_mixed_versions(self, old_kafka_version, metadata_quorum=quorum.isolated_kraft, group_protocol=
LOWtests/kafkatest/tests/core/share_consume_bench_test.py96 def test_two_share_consumers_in_a_group_topics(self, metadata_quorum):
LOWtests/kafkatest/tests/core/share_consume_bench_test.py124 def test_one_share_consumer_subscribed_to_single_topic(self, metadata_quorum):
LOWtests/kafkatest/tests/core/share_consume_bench_test.py151 def test_multiple_share_consumers_subscribed_to_single_topic(self, metadata_quorum):
LOWtests/kafkatest/tests/core/security_test.py49 def producer_consumer_have_expected_error(self, error):
LOWtests/kafkatest/tests/core/security_test.py73 def test_client_ssl_endpoint_validation_failure(self, security_protocol, interbroker_security_protocol, metadata_quo
LOWtests/kafkatest/tests/core/security_test.py145 def test_quorum_ssl_endpoint_validation_failure(self, metadata_quorum, group_protocol=None):
205 more matches not shown…
Cross-File Repetition40 hits · 200 pts
SeverityFileLineSnippet
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0|configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "123" | log
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0|configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "123" | log
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0|configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "123" | log
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "[%d] %p %m
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "[%d] %p %m
HIGH…t/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala0configuration: | appenders: | console: | name: "console" | target: "system_out" | patternlayout: | pattern: "[%d] %p %m
HIGHtests/kafkatest/tests/verifiable_share_consumer_test.py0override this since we're adding services outside of the constructor
HIGHtests/kafkatest/tests/verifiable_consumer_test.py0override this since we're adding services outside of the constructor
HIGHtests/kafkatest/tests/core/log_dir_failure_test.py0override this since we're adding services outside of the constructor
HIGHtests/kafkatest/tests/core/replication_test.py0override this since we're adding services outside of the constructor
HIGHtests/kafkatest/tests/core/quota_test.py0override this since we're adding services outside of the constructor
HIGHtests/kafkatest/tests/core/transactions_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…fkatest/tests/core/transactions_mixed_versions_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/share_consume_bench_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/security_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/produce_bench_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…fkatest/tests/core/replication_replica_failure_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/log_dir_failure_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/throttling_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/round_trip_fault_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/consume_bench_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/replication_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…s/kafkatest/tests/core/group_mode_transactions_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/reassign_partitions_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/transactions_upgrade_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/quota_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…/kafkatest/tests/core/eligible_leader_replicas_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…est/tests/client/client_compatibility_features_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/client/compression_test.py0:type test_context: ducktape.tests.test.testcontext
HIGH…ts/client/client_compatibility_produce_consume_test.py0:type test_context: ducktape.tests.test.testcontext
HIGHtests/kafkatest/tests/core/log_dir_failure_test.py0discover node of requested type. for leader type, discovers leader for our topic and partition 0
HIGHtests/kafkatest/tests/core/replication_test.py0discover node of requested type. for leader type, discovers leader for our topic and partition 0
HIGH…/kafkatest/tests/streams/streams_broker_bounce_test.py0discover node of requested type. for leader type, discovers leader for our topic and partition 0
HIGH…sts/kafkatest/services/transactional_message_copier.py0try to parse a string as json. return none if not parseable.
HIGHtests/kafkatest/services/verifiable_consumer.py0try to parse a string as json. return none if not parseable.
HIGHtests/kafkatest/services/verifiable_producer.py0try to parse a string as json. return none if not parseable.
HIGHtests/kafkatest/services/verifiable_share_consumer.py0try to parse a string as json. return none if not parseable.
HIGHtests/kafkatest/services/zookeeper.py0queries zookeeper for data associated with 'path' and returns all fields in the schema
HIGHtests/kafkatest/services/zookeeper.py0queries zookeeper for data associated with 'path' and returns all fields in the schema
HIGHtests/kafkatest/services/zookeeper.py0queries zookeeper for data associated with 'path' and returns all fields in the schema
Verbosity Indicators71 hits · 127 pts
SeverityFileLineSnippet
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1882 // Step 2: put the state machine into the appropriate... state
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1897 // Step 3: assign partitions
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1908 // Step 4: Send ack and make sure we're done and our listener was called appropriately
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1917 // Step 5: receive an empty assignment, which means we should call revoke
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1925 // Step 6: revoke partitions
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1935 // Step 7: assign partitions should still be called, even though it's empty
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1945 // Step 8: Send ack and make sure we're done and our listener was called appropriately
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1963 // Step 1: set up mocks
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1979 // Step 2: put the state machine into the appropriate... state
LOW…/consumer/internals/ConsumerMembershipManagerTest.java1994 // Step 3: revoke partitions
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2006 // Step 4: Send ack and make sure we're done and our listener was called appropriately
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2023 // Step 1: set up mocks
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2038 // Step 2: put the state machine into the appropriate... state
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2053 // Step 3: revoke partitions
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2064 // Step 4: assign partitions
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2076 // Step 5: Send ack and make sure we're done and our listener was called appropriately
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2289 // Step 1: set up mocks
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2304 // Step 2: put the state machine into the appropriate... state
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2313 // Step 3: invoke the callback
LOW…/consumer/internals/ConsumerMembershipManagerTest.java2324 // Step 4: Receive ack and make sure we're done and our listener was called appropriately
LOW…/consumer/internals/CoordinatorRequestManagerTest.java110 // Step 1: mark the coordinator as disconnected right after creation of the CoordinatorRequestManager.
LOW…/consumer/internals/CoordinatorRequestManagerTest.java115 // Step 2: sleep for one minute and mark the coordinator unknown again. Then verify that the warning was
LOW…/consumer/internals/CoordinatorRequestManagerTest.java123 // Step 3: sleep for *another* minute, mark the coordinator unknown again, and verify the accuracy.
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java528 // Step 1: Authenticate with client assertion
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java538 // Step 2: Reconfigure with only client secret (assertion configs removed)
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java560 // Step 1: Authenticate with locally-generated assertion
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java570 // Step 2: Reconfigure with file-based assertion (locally-generated configs removed)
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java600 // Step 1: Authenticate with file-based assertion
LOW…authbearer/ClientAssertionKeycloakIntegrationTest.java620 // Step 2: Reconfigure with locally-generated assertion (file config removed)
LOW…c/test/scala/unit/kafka/network/SocketServerTest.scala1476 // Step 1: Send client requests.
LOW…c/test/scala/unit/kafka/network/SocketServerTest.scala1487 // Step 2: Close the client-side socket and the proxy socket to the server, triggering close notification in the
LOW…c/test/scala/unit/kafka/network/SocketServerTest.scala1497 // Step 3: Process the first request. Verify that the channel is not removed since the channel
LOW…c/test/scala/unit/kafka/network/SocketServerTest.scala1504 // Step 4: Process buffered data. if `responseRequiredIndex>=0`, the channel should be failed and removed when
LOW…integration/kafka/api/ClientOAuthIntegrationTest.scala70 // Step 1: Generate the key pair dynamically.
LOW…integration/kafka/api/ClientOAuthIntegrationTest.scala77 // Step 2: Create the RSA JWK from key pair.
LOW…integration/kafka/api/ClientOAuthIntegrationTest.scala83 // Step 3: Create the OAuth server using the keys just created
LOW…e/src/main/java/kafka/server/share/SharePartition.java1702 // we need to check if the share partition has reached the max in-flight records limit
LOW…e/src/main/java/kafka/server/share/SharePartition.java3347 // Step 1: Enqueue to DLQ
LOW…e/src/main/java/kafka/server/share/SharePartition.java3356 // Step 2: Transition ARCHIVING → ARCHIVED
LOW…e/src/main/java/kafka/server/share/SharePartition.java3369 // Step 3: Persist ARCHIVED. On failure, ARCHIVED stays in memory — the
LOW…rc/main/java/kafka/server/share/DelayedShareFetch.java239 // tryComplete did not invoke forceComplete, so we need to check if we have any partitions to fetch.
LOW…/streams/integration/InternalTopicIntegrationTest.java202 // Step 1: Configure and start a simple word count topology
LOW…/streams/integration/InternalTopicIntegrationTest.java215 // Step 2: Produce some input data to the input topic.
LOW…/streams/integration/InternalTopicIntegrationTest.java220 // Step 3: Verify the state changelog topics are compact
LOW…/streams/integration/InternalTopicIntegrationTest.java240 // Step 1: Configure and start a simple word count topology
LOW…/streams/integration/InternalTopicIntegrationTest.java256 // Step 2: Produce some input data to the input topic.
LOW…/streams/integration/InternalTopicIntegrationTest.java261 // Step 3: Verify the state changelog topics are compact
LOW…ntegration/OuterJoinListValueStoreRestorationTest.java155 // Step 1: Initial Topology Start
LOW…ntegration/OuterJoinListValueStoreRestorationTest.java159 // Step 2: Create Non-Joined Records
LOW…ntegration/OuterJoinListValueStoreRestorationTest.java187 // Step 3: Force State Restoration
LOW…ntegration/OuterJoinListValueStoreRestorationTest.java191 // Step 4: Restart with Restoration
LOW…ntegration/OuterJoinListValueStoreRestorationTest.java195 // Step 5: Trigger Window Advancement
LOW…/internals/RocksDBTimestampedStoreWithHeadersTest.java283 // Step 1: Create a plain store with two keys
LOW…/internals/RocksDBTimestampedStoreWithHeadersTest.java290 // Step 2: Open as timestamped store and migrate one key (simulating partial migration)
LOW…/internals/RocksDBTimestampedStoreWithHeadersTest.java297 // Step 3: Try to open with headers store - should fail
LOW…ache/kafka/server/share/session/ShareSessionCache.java288 // as part of final epoch from client, so we need to check if the session is still
LOW…kafka/tiered/storage/HarnessBackedClusterInstance.java153 // Step 1: wait until a controller marks all brokers as registered and unfenced
LOW…kafka/tiered/storage/HarnessBackedClusterInstance.java161 // Step 2: wait until each broker's metadata cache knows about all alive brokers
LOW…apache/kafka/storage/internals/log/UnifiedLogTest.java4558 // Step 1: Write transactional records as leader to establish current epoch
LOW…apache/kafka/storage/internals/log/UnifiedLogTest.java4565 // Step 2: Simulate leader writing TV2 marker with bumped epoch (epoch + 1)
11 more matches not shown…
Excessive Try-Catch Wrapping47 hits · 62 pts
SeverityFileLineSnippet
LOWdocker/test/docker_sanity_test.py180 except Exception as e:
LOWdocker/test/docker_sanity_test.py185 except Exception as e:
LOWdocker/test/docker_sanity_test.py190 except Exception as e:
LOWdocker/test/docker_sanity_test.py197 except Exception as e:
LOWdocker/test/docker_sanity_test.py202 except Exception as e:
LOW…est/tests/client/client_compatibility_features_test.py52 except Exception as e:
LOW…est/tests/client/client_compatibility_features_test.py104 except Exception as e:
LOWtests/kafkatest/tests/client/share_consumer_test.py63 except Exception:
MEDIUMtests/kafkatest/tests/client/share_consumer_test.py59def leader_settled(partition_leader, topicName, partition):
LOWtests/kafkatest/services/streams.py235 except Exception as exception:
MEDIUMtests/kafkatest/services/streams.py231def pids(self, node):
LOWtests/kafkatest/services/monitor/http.py209 except Exception as e:
MEDIUMtests/kafkatest/services/monitor/http.py96def stop(self):
LOWtests/kafkatest/services/kafka/kafka.py700 except Exception:
LOWtests/kafkatest/services/kafka/kafka.py705 except Exception:
LOWtests/kafkatest/services/kafka/kafka.py1014 except Exception:
LOWrelease/release.py247 except Exception as e:
LOWrelease/release.py316except Exception as e:
MEDIUMrelease/release.py240def prereq(name, soft_check):
LOWrelease/runtime.py58 except Exception as e:
LOWrelease/notes.py172 except Exception as e:
LOWrelease/gpg.py35 except Exception:
LOW.github/scripts/pr-format.py130 except Exception as e:
MEDIUM.github/scripts/pr-format.py124def _run_json(cmd, source):
MEDIUM.github/scripts/develocity_reports.py1289 print(f"Error occurred: {str(e)}")
MEDIUM.github/scripts/develocity_reports.py108def get_cache(self) -> Optional[BuildCache]:
MEDIUM.github/scripts/develocity_reports.py128def get_cache(self) -> Optional[BuildCache]:
LOW.github/scripts/develocity_reports.py113 except Exception as e:
LOW.github/scripts/develocity_reports.py121 except Exception as e:
LOW.github/scripts/develocity_reports.py141 except Exception as e:
LOW.github/scripts/develocity_reports.py155 except Exception as e:
LOW.github/scripts/develocity_reports.py394 except Exception as e:
LOW.github/scripts/develocity_reports.py598 except Exception as e:
LOW.github/scripts/develocity_reports.py818 except Exception as e:
LOW.github/scripts/develocity_reports.py914 except Exception as e:
LOW.github/scripts/develocity_reports.py1287 except Exception as e:
LOWcommitter-tools/refresh_collaborators.py149 except Exception as e:
MEDIUMcommitter-tools/verify_license.py45 print("Error: Distributions directory not found:", distributions_dir)
MEDIUMcommitter-tools/verify_license.py55 print("Error: No tarball matching 'kafka_2.13-*.tgz' found in:", distributions_dir)
MEDIUMcommitter-tools/verify_license.py100 print("Error: No directory found after extraction.")
MEDIUMcommitter-tools/verify_license.py109 print("Error: LICENSE file or libs directory not found in the extracted project.")
LOWcommitter-tools/kafka-merge-pr.py142 except Exception as error:
LOWcommitter-tools/kafka-merge-pr.py202 except Exception as error:
LOWcommitter-tools/kafka-merge-pr.py225 except Exception as error:
LOWcommitter-tools/kafka-merge-pr.py236 except Exception as error:
LOWcommitter-tools/kafka-merge-pr.py274 except Exception as error:
MEDIUMcommitter-tools/kafka-merge-pr.py77def get_json(url):
Unused Imports62 hits · 61 pts
SeverityFileLineSnippet
LOWdocker/generate_kafka_pr_template.py36
LOW…s/kafkatest/sanity_checks/test_performance_services.py17
LOW…fkatest/tests/core/transactions_mixed_versions_test.py20
LOW…fkatest/tests/core/transactions_mixed_versions_test.py23
LOW…fkatest/tests/core/transactions_mixed_versions_test.py32
LOW…fkatest/tests/core/replication_replica_failure_test.py20
LOW…fkatest/tests/core/replication_replica_failure_test.py25
LOW…fkatest/tests/core/replication_replica_failure_test.py27
LOW…fkatest/tests/core/replication_replica_failure_test.py30
LOW…fkatest/tests/core/replication_replica_failure_test.py31
LOWtests/kafkatest/tests/core/round_trip_fault_test.py27
LOWtests/kafkatest/tests/core/replication_test.py19
LOW…atest/tests/core/compatibility_test_new_broker_test.py13
LOWtests/kafkatest/tests/core/upgrade_test.py16
LOWtests/kafkatest/tests/core/upgrade_test.py20
LOWtests/kafkatest/tests/core/snapshot_test.py16
LOWtests/kafkatest/tests/core/transactions_upgrade_test.py20
LOWtests/kafkatest/tests/core/transactions_upgrade_test.py32
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py18
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py22
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py25
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py25
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py25
LOW…est/tests/streams/streams_broker_compatibility_test.py16
LOW…test/tests/streams/streams_application_upgrade_test.py23
LOW…test/tests/streams/streams_application_upgrade_test.py23
LOWtests/kafkatest/tests/streams/utils/__init__.py16
LOWtests/kafkatest/tests/streams/utils/__init__.py16
LOWtests/kafkatest/tests/streams/utils/__init__.py16
LOWtests/kafkatest/tests/streams/utils/__init__.py16
LOWtests/kafkatest/tests/streams/utils/__init__.py16
LOWtests/kafkatest/tests/connect/connect_test.py23
LOW…atest/tests/client/consumer_protocol_migration_test.py21
LOWtests/kafkatest/tests/client/consumer_test.py21
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/utils/__init__.py16
LOWtests/kafkatest/services/console_consumer.py24
LOWtests/kafkatest/services/console_share_consumer.py20
LOWtests/kafkatest/services/console_share_consumer.py24
LOWtests/kafkatest/services/monitor/jmx.py22
LOWtests/kafkatest/services/security/kafka_acls.py16
LOWtests/kafkatest/services/kafka/__init__.py16
LOWtests/kafkatest/services/kafka/__init__.py17
LOWtests/kafkatest/services/kafka/__init__.py18
LOWtests/kafkatest/services/performance/__init__.py16
LOWtests/kafkatest/services/performance/__init__.py16
LOWtests/kafkatest/services/performance/__init__.py16
LOWtests/kafkatest/services/performance/__init__.py16
LOWtests/kafkatest/services/performance/__init__.py17
LOWtests/kafkatest/services/performance/__init__.py18
LOWtests/kafkatest/services/performance/__init__.py19
LOWtests/kafkatest/services/performance/__init__.py20
LOWrelease/release.py57
LOWrelease/svn.py24
LOW.github/scripts/checkstyle.py21
LOW.github/scripts/develocity_reports.py20
2 more matches not shown…
AI Slop Vocabulary13 hits · 32 pts
SeverityFileLineSnippet
MEDIUM…a/org/apache/kafka/clients/producer/KafkaProducer.java729 * {@link KafkaConsumer#groupMetadata()} to leverage consumer group metadata. This will provide
MEDIUM…a/org/apache/kafka/clients/admin/KafkaAdminClient.java4865 // Simply leverage the existing fenceProducers implementation with a single transactional ID
LOW…a/org/apache/kafka/clients/consumer/KafkaConsumer.java306 * To use this mode, instead of subscribing to the topic using {@link #subscribe(Collection) subscribe}, you just call
LOW…a/org/apache/kafka/clients/consumer/KafkaConsumer.java642 * partitions using {@link #assign(Collection)} then this will simply return the same partitions that
LOW…org/apache/kafka/common/internals/KafkaFutureImpl.java65 // function. CompletableFuture#thenApply will just return ExecutionException wrapping the
MEDIUMcore/src/main/scala/kafka/server/ReplicaManager.scala893 // Please refer to the documentation in `DelayedProduce#tryComplete` for a comprehensive description of thes
LOWvagrant/base.sh209# VMs, we can just create it if it doesn't exist and use it like we'd use
MEDIUM…/streams/processor/internals/StoreChangelogReader.java132 // NOTE we do not book keep the current offset since we leverage state manager as its source of truth
LOWtests/kafkatest/tests/core/transactions_test.py226 # To check ordering, we simply create input and output topics
MEDIUMtests/kafkatest/tests/core/reassign_partitions_test.py137 # latter is more robust.
MEDIUM…/kafkatest/tests/streams/streams_broker_bounce_test.py188 # Start test harness
MEDIUMtests/kafkatest/services/monitor/jmx.py63 # JmxTool is not particularly robust to slow-starting processes. In order to ensure JmxTool doesn't fail if the
MEDIUM…he/kafka/connect/runtime/WorkerTransactionContext.java83 // Essentially, instead of telling the task that it screwed up and trusting it to do the right thing, we rat on
Deep Nesting30 hits · 24 pts
SeverityFileLineSnippet
LOWtests/kafkatest/tests/core/quota_test.py33
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py255
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py334
LOWtests/kafkatest/tests/streams/streams_upgrade_test.py416
LOW…test/tests/streams/streams_application_upgrade_test.py236
LOW…ts/kafkatest/tests/connect/connect_distributed_test.py566
LOW…sts/kafkatest/services/transactional_message_copier.py76
LOWtests/kafkatest/services/verifiable_consumer.py93
LOWtests/kafkatest/services/verifiable_consumer.py303
LOWtests/kafkatest/services/verifiable_consumer.py363
LOWtests/kafkatest/services/verifiable_producer.py125
LOWtests/kafkatest/services/verifiable_share_consumer.py145
LOWtests/kafkatest/services/kafka/kafka.py194
LOWtests/kafkatest/services/kafka/kafka.py601
LOWtests/kafkatest/services/kafka/kafka.py848
LOWtests/kafkatest/services/kafka/kafka.py1513
LOWrelease/textfiles.py55
LOW.github/scripts/pr-format.py107
LOW.github/scripts/format-test-catalog.py32
LOW.github/scripts/checkstyle.py38
LOW.github/scripts/junit.py144
LOW.github/scripts/develocity_reports.py966
LOW.github/scripts/develocity_reports.py226
LOW.github/scripts/develocity_reports.py313
LOW.github/scripts/develocity_reports.py415
LOW.github/scripts/develocity_reports.py560
LOW.github/scripts/develocity_reports.py603
LOW.github/scripts/develocity_reports.py740
LOW.github/scripts/develocity_reports.py845
LOWcommitter-tools/refresh_collaborators.py78
Self-Referential Comments9 hits · 23 pts
SeverityFileLineSnippet
MEDIUMdocker/generate_kafka_pr_template.py69# This file is generated via https://github.com/apache/kafka/blob/{file_commit(os.path.join(current_dir, self))}/docker/
MEDIUMtests/setup.cfg18# This file defines naming convention and root search directory for autodiscovery of
MEDIUMtests/kafkatest/tests/produce_consume_validate.py22 """This class provides a shared template for tests which follow the common pattern of:
MEDIUMtests/kafkatest/tests/end_to_end.py27 """This class provides a shared template for tests which follow the common pattern of:
MEDIUMtests/kafkatest/tests/core/snapshot_test.py131 # Create a new topic
MEDIUMtests/kafkatest/tests/core/snapshot_test.py197 # Create a topic where the affected broker must be the leader
MEDIUM…kafkatest/tests/streams/templates/log4j2_template.yaml16# Define the root logger with appender file
MEDIUMtests/kafkatest/services/streams.py220 # Create a randomized state directory path to prevent test interference
MEDIUMtests/kafkatest/services/trogdor/trogdor.py133 # Create the configuration file on the node.
Synthetic Comment Markers2 hits · 15 pts
SeverityFileLineSnippet
HIGH…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java273 // Offset commit as requested when pausing; No records returned by consumer.poll()
HIGH…g/apache/kafka/connect/runtime/WorkerSinkTaskTest.java317 // Offset commit as requested when pausing; No records returned by consumer.poll()
Cross-Language Confusion2 hits · 10 pts
SeverityFileLineSnippet
HIGHtests/kafkatest/services/kafka/kafka.py1459 cmd += "&& sleep 1 && rm -f %s" % json_file
HIGHtests/kafkatest/services/kafka/kafka.py1501 cmd += " && sleep 1 && rm -f %s" % json_file
Redundant / Tautological Comments5 hits · 8 pts
SeverityFileLineSnippet
LOWtests/kafkatest/tests/core/snapshot_test.py117 # Check if the first log segment is cleaned up
LOW.github/workflows/build.yml167 # Check if there are any empty files under ./site-docs/generated, If any empty files are found, print an error
LOW.github/scripts/develocity_reports.py130 # Check if running in GitHub Actions
LOW.github/scripts/develocity_reports.py728 # Check if there's a significant increase in flakiness
LOW.github/scripts/develocity_reports.py766 # Check if the test meets clearing criteria at class level
Slop Phrases3 hits · 8 pts
SeverityFileLineSnippet
MEDIUM…a/org/apache/kafka/clients/producer/KafkaProducer.java109 * Here is a simple example of using the producer to send records with strings containing sequential numbers as the key/
MEDIUM…rc/main/java/org/apache/kafka/clients/admin/Admin.java77 * Here is a simple example of using an Admin client instance to create a new topic:
LOW.github/workflows/build.yml186 # If we change these, make sure to adjust ci-complete.yml
Fake / Example Data5 hits · 5 pts
SeverityFileLineSnippet
LOW…er/internals/OAuthBearerClientInitialResponseTest.java102 assertEquals("user@example.com", response.authorizationId());
LOW…er/internals/OAuthBearerClientInitialResponseTest.java114 assertEquals("user@example.com", response.authorizationId());
LOW…er/internals/OAuthBearerClientInitialResponseTest.java125 assertEquals("user@example.com", response.authorizationId());
LOW…pache/kafka/connect/file/FileStreamSourceTaskTest.java135 "Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy
LOW…pache/kafka/connect/file/FileStreamSourceTaskTest.java135 "Neque porro quisquam est qui dolorem ipsum quia dolor sit amet, consectetur, adipisci velit...\n".getBy