8,627 results
« Page 54 of 87 »
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share scanned directory share
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister scanned directory persister
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java scanned file 31.0 KB DefaultStatePersister.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateParameters.java scanned file 3.3 KB DeleteShareGroupStateParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/DeleteShareGroupStateResult.java scanned file 2.5 KB DeleteShareGroupStateResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/GroupTopicPartitionData.java scanned file 3.0 KB GroupTopicPartitionData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateParameters.java scanned file 2.8 KB InitializeShareGroupStateParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/InitializeShareGroupStateResult.java scanned file 3.5 KB InitializeShareGroupStateResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java scanned file 6.1 KB NoOpStatePersister.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionAllData.java scanned file 1.2 KB PartitionAllData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionData.java scanned file 5.8 KB PartitionData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionErrorData.java scanned file 1.1 KB PartitionErrorData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java scanned file 3.7 KB PartitionFactory.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdData.java scanned file 1.1 KB PartitionIdData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdLeaderEpochData.java scanned file 1.1 KB PartitionIdLeaderEpochData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionInfoData.java scanned file 1.0 KB PartitionInfoData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateBatchData.java scanned file 1.2 KB PartitionStateBatchData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateData.java scanned file 1.1 KB PartitionStateData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateErrorData.java scanned file 1.2 KB PartitionStateErrorData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java scanned file 1.2 KB PartitionStateSummaryData.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/Persister.java scanned file 2.7 KB Persister.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterParameters.java scanned file 990 bytes PersisterParameters.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterResult.java scanned file 983 bytes PersisterResult.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateBatch.java scanned file 4.7 KB PersisterStateBatch.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java scanned file 83.6 KB PersisterStateManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateParameters.java scanned file 2.9 KB ReadShareGroupStateParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateResult.java scanned file 3.0 KB ReadShareGroupStateResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryParameters.java scanned file 3.2 KB ReadShareGroupStateSummaryParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/ReadShareGroupStateSummaryResult.java scanned file 2.9 KB ReadShareGroupStateSummaryResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/ShareCoordinatorMetadataCacheHelper.java scanned file 1.2 KB ShareCoordinatorMetadataCacheHelper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/TopicData.java scanned file 2.1 KB TopicData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateParameters.java scanned file 3.4 KB WriteShareGroupStateParameters.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/WriteShareGroupStateResult.java scanned file 2.5 KB WriteShareGroupStateResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/SharePartitionKey.java scanned file 5.3 KB SharePartitionKey.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage scanned directory storage
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log scanned directory log
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log/FetchIsolation.java scanned file 1.5 KB FetchIsolation.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log/FetchParams.java scanned file 4.5 KB FetchParams.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log/FetchPartitionData.java scanned file 2.5 KB FetchPartitionData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log/UnexpectedAppendOffsetException.java scanned file 1.5 KB UnexpectedAppendOffsetException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util scanned directory util
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/CommandDefaultOptions.java scanned file 1.6 KB CommandDefaultOptions.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/CommandLineUtils.java scanned file 10.6 KB CommandLineUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/Csv.java scanned file 2.1 KB Csv.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/Deadline.java scanned file 2.2 KB Deadline.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/FileLock.java scanned file 3.2 KB FileLock.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/FutureUtils.java scanned file 5.8 KB FutureUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java scanned file 9.8 KB InterBrokerSendThread.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/json scanned directory json
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/json/DecodeJson.java scanned file 4.5 KB DecodeJson.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/Json.java scanned file 4.2 KB Json.java .java Java text/x-Algol68 apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/json/JsonArray.java scanned file 2.0 KB JsonArray.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/json/JsonObject.java scanned file 1.9 KB JsonObject.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/json/JsonValue.java scanned file 4.7 KB JsonValue.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/KafkaScheduler.java scanned file 6.6 KB KafkaScheduler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/LockUtils.java scanned file 3.5 KB LockUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/RequestAndCompletionHandler.java scanned file 1.9 KB RequestAndCompletionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/Scheduler.java scanned file 2.2 KB Scheduler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/ShutdownableThread.java scanned file 4.9 KB ShutdownableThread.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/ThroughputThrottler.java scanned file 4.9 KB ThroughputThrottler.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer scanned directory timer
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/SystemTimer.java scanned file 4.2 KB SystemTimer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/SystemTimerReaper.java scanned file 2.5 KB SystemTimerReaper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/Timer.java scanned file 1.5 KB Timer.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTaskEntry.java scanned file 2.0 KB TimerTaskEntry.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTask.java scanned file 1.8 KB TimerTask.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTaskList.java scanned file 4.5 KB TimerTaskList.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimingWheel.java scanned file 8.7 KB TimingWheel.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/TranslatedValueMapView.java scanned file 3.8 KB TranslatedValueMapView.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline scanned directory timeline
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/BaseHashTable.java scanned file 8.9 KB BaseHashTable.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/Delta.java scanned file 1.1 KB Delta.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/Revertable.java scanned file 1.3 KB Revertable.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/Snapshot.java scanned file 3.3 KB Snapshot.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java scanned file 11.5 KB SnapshotRegistry.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java scanned file 17.5 KB SnapshottableHashTable.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/TimelineHashMap.java scanned file 10.9 KB TimelineHashMap.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/TimelineHashSet.java scanned file 6.6 KB TimelineHashSet.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/TimelineInteger.java scanned file 3.4 KB TimelineInteger.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/TimelineLong.java scanned file 3.4 KB TimelineLong.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/TimelineObject.java scanned file 3.6 KB TimelineObject.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/common scanned directory common
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/common/DirectoryIdTest.java scanned file 3.6 KB DirectoryIdTest.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/deferred scanned directory deferred
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/deferred/DeferredEventQueueTest.java scanned file 4.3 KB DeferredEventQueueTest.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/metadata scanned directory metadata
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 scanned directory queue
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 scanned directory server
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common scanned directory common
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