6,866 results
« Page 45 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/metadata/AssignmentsHelperTest.java scanned file 5.1 KB AssignmentsHelperTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java scanned file 21.6 KB KafkaEventQueueTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/FeatureTest.java scanned file 13.6 KB FeatureTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/FinalizedFeaturesTest.java scanned file 2.3 KB FinalizedFeaturesTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/KRaftVersionTest.java scanned file 4.8 KB KRaftVersionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTest.java scanned file 14.0 KB MetadataVersionTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTestUtils.java scanned file 1.1 KB MetadataVersionTestUtils.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/ProducerIdsBlockTest.java scanned file 2.7 KB ProducerIdsBlockTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/LoggingFaultHandlerTest.java scanned file 1.9 KB LoggingFaultHandlerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/MockFaultHandler.java scanned file 2.4 KB MockFaultHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/ProcessTerminatingFaultHandlerTest.java scanned file 2.9 KB ProcessTerminatingFaultHandlerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/DelegationChecker.java scanned file 7.8 KB DelegationChecker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableMapTest.java scanned file 15.0 KB PCollectionsImmutableMapTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableNavigableSetTest.java scanned file 20.7 KB PCollectionsImmutableNavigableSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableSetTest.java scanned file 12.2 KB PCollectionsImmutableSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/IntegrationTestUtils.java scanned file 3.3 KB IntegrationTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/KafkaMetricsGroupTest.java scanned file 1.4 KB KafkaMetricsGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/KafkaYammerMetricsTest.java scanned file 3.4 KB KafkaYammerMetricsTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/TimeRatioTest.java scanned file 2.4 KB TimeRatioTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/mutable/BoundedListTest.java scanned file 7.4 KB BoundedListTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/network/EndpointReadyFuturesTest.java scanned file 7.2 KB EndpointReadyFuturesTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/purgatory/DelayedOperationTest.java scanned file 12.7 KB DelayedOperationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/quota/QuotaUtilsTest.java scanned file 5.9 KB QuotaUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/record/BrokerCompressionTypeTest.java scanned file 2.8 KB BrokerCompressionTypeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share/persister/DefaultStatePersisterTest.java scanned file 79.8 KB DefaultStatePersisterTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share/persister/PersisterStateManagerTest.java scanned file 199.4 KB PersisterStateManagerTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/CommandLineUtilsTest.java scanned file 15.5 KB CommandLineUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/CsvTest.java scanned file 2.6 KB CsvTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/DeadlineTest.java scanned file 2.6 KB DeadlineTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/FileLockTest.java scanned file 3.2 KB FileLockTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/FutureUtilsTest.java scanned file 5.5 KB FutureUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java scanned file 14.2 KB InterBrokerSendThreadTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/JsonTest.java scanned file 9.9 KB JsonTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockRandom.java scanned file 1.3 KB MockRandom.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockScheduler.java scanned file 6.0 KB MockScheduler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockTime.java scanned file 1.7 KB MockTime.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/ShutdownableThreadTest.java scanned file 5.5 KB ShutdownableThreadTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/MockTimer.java scanned file 2.8 KB MockTimer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/SystemTimerReaperTest.java scanned file 2.7 KB SystemTimerReaperTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTaskListTest.java scanned file 4.0 KB TimerTaskListTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java scanned file 4.9 KB TimerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimingWheelTest.java scanned file 7.3 KB TimingWheelTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/TranslatedValueMapViewTest.java scanned file 4.2 KB TranslatedValueMapViewTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java scanned file 5.5 KB BaseHashTableTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/SnapshotRegistryTest.java scanned file 4.7 KB SnapshotRegistryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/SnapshottableHashTableTest.java scanned file 13.6 KB SnapshottableHashTableTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineHashMapTest.java scanned file 4.5 KB TimelineHashMapTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineHashSetTest.java scanned file 4.5 KB TimelineHashSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineIntegerTest.java scanned file 3.1 KB TimelineIntegerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineLongTest.java scanned file 3.1 KB TimelineLongTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineObjectTest.java scanned file 3.2 KB TimelineObjectTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TrackingSnapshotRegistry.java scanned file 1.7 KB TrackingSnapshotRegistry.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/resources/log4j2.yaml scanned file 1.1 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/ConnectionQuotaEntity.java scanned file 3.3 KB ConnectionQuotaEntity.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/ConnectionThrottledException.java scanned file 1.3 KB ConnectionThrottledException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/metrics/RequestChannelMetrics.java scanned file 2.3 KB RequestChannelMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/metrics/RequestMetrics.java scanned file 10.9 KB RequestMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java scanned file 59.0 KB RequestConvertToJson.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/Session.java scanned file 1.3 KB Session.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/SocketServerConfigs.java scanned file 16.6 KB SocketServerConfigs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/TooManyConnectionsException.java scanned file 1.2 KB TooManyConnectionsException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security/authorizer/AclEntry.java scanned file 3.9 KB AclEntry.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security/authorizer/AuthorizerUtils.java scanned file 1.6 KB AuthorizerUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ActionQueue.java scanned file 1.1 KB ActionQueue.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ApiVersionManager.java scanned file 2.8 KB ApiVersionManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/Assignment.java scanned file 2.4 KB Assignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunction.java scanned file 3.4 KB AssignmentsManagerDeadlineFunction.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java scanned file 18.6 KB AssignmentsManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/BrokerFeatures.java scanned file 7.3 KB BrokerFeatures.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java scanned file 32.6 KB ClientMetricsManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java scanned file 9.8 KB AbstractKafkaConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ClientQuotaManagerConfig.java scanned file 1.6 KB ClientQuotaManagerConfig.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/DynamicProducerStateManagerConfig.java scanned file 3.6 KB DynamicProducerStateManagerConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ConfigHelperUtils.java scanned file 4.2 KB ConfigHelperUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/KRaftConfigs.java scanned file 6.4 KB KRaftConfigs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ReplicationConfigs.java scanned file 14.9 KB ReplicationConfigs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ReplicationQuotaManagerConfig.java scanned file 2.1 KB ReplicationQuotaManagerConfig.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/DefaultApiVersionManager.java scanned file 4.8 KB DefaultApiVersionManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/DelayedActionQueue.java scanned file 2.0 KB DelayedActionQueue.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/DynamicThreadPool.java scanned file 3.2 KB DynamicThreadPool.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/LeaderEndPoint.java scanned file 4.5 KB LeaderEndPoint.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/logger/Log4jCoreController.java scanned file 3.3 KB Log4jCoreController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/logger/LoggingControllerDelegate.java scanned file 1.1 KB LoggingControllerDelegate.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/logger/LoggingController.java scanned file 4.0 KB LoggingController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/logger/LoggingControllerMBean.java scanned file 1.0 KB LoggingControllerMBean.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/logger/NoOpController.java scanned file 1.2 KB NoOpController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/BrokerServerMetrics.java scanned file 7.7 KB BrokerServerMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsConfigs.java scanned file 9.8 KB ClientMetricsConfigs.java .java Java text/html apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsInstance.java scanned file 4.7 KB ClientMetricsInstance.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/ClientMetricsInstanceMetadata.java scanned file 2.8 KB ClientMetricsInstanceMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/ClientTelemetryExporterPlugin.java scanned file 3.0 KB ClientTelemetryExporterPlugin.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/DefaultClientTelemetryContext.java scanned file 1.2 KB DefaultClientTelemetryContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/DefaultClientTelemetryPayload.java scanned file 2.0 KB DefaultClientTelemetryPayload.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java scanned file 5.0 KB ForwardingManagerMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/LinuxIoMetricsCollector.java scanned file 3.7 KB LinuxIoMetricsCollector.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/MetricConfigs.java scanned file 5.7 KB MetricConfigs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/metrics/NodeMetrics.java scanned file 3.2 KB NodeMetrics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/package-info.java scanned file 902 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/AlterPartitionListener.java scanned file 1.3 KB AlterPartitionListener.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/AssignmentState.java scanned file 1.6 KB AssignmentState.java .java Java text/x-java apache-2.0