8,627 results
« Page 57 of 87 »
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java scanned file 4.6 KB SocketServerConfigsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/security scanned directory security
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/security/authorizer scanned directory authorizer
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/security/authorizer/AuthorizerUtilsTest.java scanned file 5.8 KB AuthorizerUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server scanned directory server
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunctionTest.java scanned file 3.3 KB AssignmentsManagerDeadlineFunctionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java scanned file 24.3 KB AssignmentsManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentTest.java scanned file 4.4 KB AssignmentTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BootstrapControllersIntegrationTest.java scanned file 19.0 KB BootstrapControllersIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BrokerFeaturesTest.java scanned file 5.7 KB BrokerFeaturesTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BrokerRegistrationRequestTest.java scanned file 10.1 KB BrokerRegistrationRequestTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java scanned file 78.7 KB ClientMetricsManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/config scanned directory config
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/config/DelegationTokenManagerConfigsTest.java scanned file 3.9 KB DelegationTokenManagerConfigsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/config/MinInSyncReplicasConfigTest.java scanned file 1.4 KB MinInSyncReplicasConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/EligibleLeaderReplicasIntegrationTest.java scanned file 21.6 KB EligibleLeaderReplicasIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/KRaftClusterTest.java scanned file 17.7 KB KRaftClusterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/LogManagerIntegrationTest.java scanned file 8.7 KB LogManagerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/BrokerServerMetricsTest.java scanned file 7.1 KB BrokerServerMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceMetadataTest.java scanned file 7.2 KB ClientMetricsInstanceMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceTest.java scanned file 4.3 KB ClientMetricsInstanceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsTelemetryPluginTest.java scanned file 6.7 KB ClientMetricsTelemetryPluginTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsTestUtils.java scanned file 6.5 KB ClientMetricsTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientTelemetryTest.java scanned file 3.9 KB ClientTelemetryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ForwardingManagerMetricsTest.java scanned file 6.3 KB ForwardingManagerMetricsTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/LinuxIoMetricsCollectorTest.java scanned file 3.5 KB LinuxIoMetricsCollectorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/NodeMetricsTest.java scanned file 4.4 KB NodeMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java scanned file 7.3 KB MonitorablePluginsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/purgatory scanned directory purgatory
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/purgatory/DelayedFutureTest.java scanned file 5.9 KB DelayedFutureTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota scanned directory quota
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java scanned file 33.4 KB ClientQuotasRequestTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ClientSensorsTest.java scanned file 4.0 KB ClientSensorsTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ThrottledChannelTest.java scanned file 2.1 KB ThrottledChannelTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/ReconfigurableQuorumIntegrationTest.java scanned file 14.8 KB ReconfigurableQuorumIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/replica scanned directory replica
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/replica/ReplicaTest.java scanned file 8.9 KB ReplicaTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share scanned directory share
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/CachedSharePartitionTest.java scanned file 3.3 KB CachedSharePartitionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch scanned directory fetch
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKeyTest.java scanned file 2.7 KB DelayedShareFetchKeyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategyTest.java scanned file 5.0 KB PartitionMaxBytesStrategyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/PartitionRotateStrategyTest.java scanned file 4.1 KB PartitionRotateStrategyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/RecordStateTest.java scanned file 3.9 KB RecordStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java scanned file 14.2 KB ShareFetchTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTestUtils.java scanned file 6.0 KB ShareFetchTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session scanned directory session
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionCacheTest.java scanned file 15.6 KB ShareSessionCacheTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionKeyTest.java scanned file 1.6 KB ShareSessionKeyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionTest.java scanned file 2.0 KB ShareSessionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/transaction scanned directory transaction
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/transaction/AddPartitionsToTxnManagerTest.java scanned file 28.4 KB AddPartitionsToTxnManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/util scanned directory util
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/util/SchedulerTest.java scanned file 11.8 KB SchedulerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/settings.gradle scanned file 4.0 KB settings.gradle .gradle Groovy text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator scanned directory share-coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share scanned directory share
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/metrics/ShareCoordinatorMetrics.java scanned file 7.6 KB ShareCoordinatorMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/metrics/ShareCoordinatorMetricsShard.java scanned file 2.2 KB ShareCoordinatorMetricsShard.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/metrics/ShareCoordinatorRuntimeMetrics.java scanned file 1.3 KB ShareCoordinatorRuntimeMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/PersisterStateBatchCombiner.java scanned file 16.8 KB PersisterStateBatchCombiner.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java scanned file 10.8 KB ShareCoordinatorConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinator.java scanned file 6.2 KB ShareCoordinator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorOffsetsManager.java scanned file 5.1 KB ShareCoordinatorOffsetsManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordHelpers.java scanned file 4.1 KB ShareCoordinatorRecordHelpers.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordSerde.java scanned file 1.7 KB ShareCoordinatorRecordSerde.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java scanned file 54.9 KB ShareCoordinatorService.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java scanned file 50.4 KB ShareCoordinatorShard.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java scanned file 9.8 KB ShareGroupOffset.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common scanned directory common
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message scanned directory message
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareSnapshotKey.json scanned file 1.2 KB ShareSnapshotKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareSnapshotValue.json scanned file 2.6 KB ShareSnapshotValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareUpdateKey.json scanned file 1.2 KB ShareUpdateKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareUpdateValue.json scanned file 2.3 KB ShareUpdateValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share scanned directory share
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/metrics/ShareCoordinatorMetricsTest.java scanned file 5.8 KB ShareCoordinatorMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/PersisterStateBatchCombinerTest.java scanned file 16.7 KB PersisterStateBatchCombinerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfigTest.java scanned file 1.9 KB ShareCoordinatorConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorOffsetsManagerTest.java scanned file 12.6 KB ShareCoordinatorOffsetsManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordHelpersTest.java scanned file 5.5 KB ShareCoordinatorRecordHelpersTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorRecordSerdeTest.java scanned file 8.6 KB ShareCoordinatorRecordSerdeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/share-coordinator/src/test/java/org/apache/kafka/coordinator/share/ShareCoordinatorServiceTest.java scanned file 93.2 KB ShareCoordinatorServiceTest.java .java Java text/x-c++ apache-2.0