jar

org.apache.kafka : kafka-storage

Maven & Gradle

Jul 14, 2023
5 usages

Apache Kafka

Table Of Contents

Latest Version

Download org.apache.kafka : kafka-storage JAR file - Latest Versions:

All Versions

Download org.apache.kafka : kafka-storage JAR file - All Versions:

Version Vulnerabilities Size Updated
3.5.x
3.4.x
3.3.x
3.2.x
3.1.x
3.0.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window kafka-storage-3.5.1.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

org.apache.kafka.server.log.remote.metadata.storage.serialization

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemoteLogMetadataSerde.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemoteLogMetadataTransform.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemoteLogSegmentMetadataSnapshotTransform.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemoteLogSegmentMetadataTransform.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemoteLogSegmentMetadataUpdateTransform.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.serialization.RemotePartitionDeleteMetadataTransform.class - [JAR]

org.apache.kafka.server.log.remote.metadata.storage

├─ org.apache.kafka.server.log.remote.metadata.storage.ClassLoaderAwareRemoteLogMetadataManager.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.CommittedOffsetsFile.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.ConsumerManager.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.ConsumerTask.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.FileBasedRemoteLogMetadataCache.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.ProducerManager.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemoteLogLeaderEpochState.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemoteLogMetadataCache.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemoteLogMetadataSnapshotFile.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemoteLogMetadataTopicPartitioner.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemoteLogSegmentMetadataSnapshot.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemotePartitionMetadataEventHandler.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.RemotePartitionMetadataStore.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManager.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.TopicBasedRemoteLogMetadataManagerConfig.class - [JAR]

org.apache.kafka.storage.internals.log

├─ org.apache.kafka.storage.internals.log.AbortedTxn.class - [JAR]

├─ org.apache.kafka.storage.internals.log.AbstractIndex.class - [JAR]

├─ org.apache.kafka.storage.internals.log.AppendOrigin.class - [JAR]

├─ org.apache.kafka.storage.internals.log.BatchMetadata.class - [JAR]

├─ org.apache.kafka.storage.internals.log.CleanerConfig.class - [JAR]

├─ org.apache.kafka.storage.internals.log.CompletedTxn.class - [JAR]

├─ org.apache.kafka.storage.internals.log.CorruptIndexException.class - [JAR]

├─ org.apache.kafka.storage.internals.log.CorruptSnapshotException.class - [JAR]

├─ org.apache.kafka.storage.internals.log.EpochEntry.class - [JAR]

├─ org.apache.kafka.storage.internals.log.FetchDataInfo.class - [JAR]

├─ org.apache.kafka.storage.internals.log.FetchIsolation.class - [JAR]

├─ org.apache.kafka.storage.internals.log.FetchParams.class - [JAR]

├─ org.apache.kafka.storage.internals.log.FetchPartitionData.class - [JAR]

├─ org.apache.kafka.storage.internals.log.IndexEntry.class - [JAR]

├─ org.apache.kafka.storage.internals.log.IndexOffsetOverflowException.class - [JAR]

├─ org.apache.kafka.storage.internals.log.IndexSearchType.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LastRecord.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LazyIndex.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LeaderHwChange.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LoadedLogOffsets.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogAppendInfo.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogConfig.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogDirFailureChannel.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogFileUtils.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogOffsetMetadata.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogOffsetSnapshot.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogOffsetsListener.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogReadInfo.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogStartOffsetIncrementReason.class - [JAR]

├─ org.apache.kafka.storage.internals.log.LogValidator.class - [JAR]

├─ org.apache.kafka.storage.internals.log.OffsetIndex.class - [JAR]

├─ org.apache.kafka.storage.internals.log.OffsetMap.class - [JAR]

├─ org.apache.kafka.storage.internals.log.OffsetPosition.class - [JAR]

├─ org.apache.kafka.storage.internals.log.ProducerAppendInfo.class - [JAR]

├─ org.apache.kafka.storage.internals.log.ProducerStateEntry.class - [JAR]

├─ org.apache.kafka.storage.internals.log.ProducerStateManager.class - [JAR]

├─ org.apache.kafka.storage.internals.log.ProducerStateManagerConfig.class - [JAR]

├─ org.apache.kafka.storage.internals.log.RecordValidationException.class - [JAR]

├─ org.apache.kafka.storage.internals.log.RollParams.class - [JAR]

├─ org.apache.kafka.storage.internals.log.SkimpyOffsetMap.class - [JAR]

├─ org.apache.kafka.storage.internals.log.SnapshotFile.class - [JAR]

├─ org.apache.kafka.storage.internals.log.StorageAction.class - [JAR]

├─ org.apache.kafka.storage.internals.log.ThrottledReplicaListValidator.class - [JAR]

├─ org.apache.kafka.storage.internals.log.TimeIndex.class - [JAR]

├─ org.apache.kafka.storage.internals.log.TimestampOffset.class - [JAR]

├─ org.apache.kafka.storage.internals.log.TransactionIndex.class - [JAR]

├─ org.apache.kafka.storage.internals.log.TxnIndexSearchResult.class - [JAR]

├─ org.apache.kafka.storage.internals.log.TxnMetadata.class - [JAR]

org.apache.kafka.storage.internals.checkpoint

├─ org.apache.kafka.storage.internals.checkpoint.CheckpointFileWithFailureHandler.class - [JAR]

├─ org.apache.kafka.storage.internals.checkpoint.InMemoryLeaderEpochCheckpoint.class - [JAR]

├─ org.apache.kafka.storage.internals.checkpoint.LeaderEpochCheckpoint.class - [JAR]

├─ org.apache.kafka.storage.internals.checkpoint.LeaderEpochCheckpointFile.class - [JAR]

org.apache.kafka.storage.internals.epoch

├─ org.apache.kafka.storage.internals.epoch.LeaderEpochFileCache.class - [JAR]

org.apache.kafka.server.log.remote.storage

├─ org.apache.kafka.server.log.remote.storage.ClassLoaderAwareRemoteStorageManager.class - [JAR]

├─ org.apache.kafka.server.log.remote.storage.RemoteLogManagerConfig.class - [JAR]

org.apache.kafka.server.log.remote.metadata.storage.generated

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.MetadataJsonConverters.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.MetadataRecordType.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataRecord.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataRecordJsonConverter.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataSnapshotRecord.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataSnapshotRecordJsonConverter.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataUpdateRecord.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemoteLogSegmentMetadataUpdateRecordJsonConverter.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemotePartitionDeleteMetadataRecord.class - [JAR]

├─ org.apache.kafka.server.log.remote.metadata.storage.generated.RemotePartitionDeleteMetadataRecordJsonConverter.class - [JAR]

Advertisement

Dependencies from Group

Jul 14, 2023
1.7k usages
Jul 14, 2023
706 usages
Mar 03, 2020
596 usages
Jul 14, 2023
545 usages
Jul 14, 2023
388 usages

Discover Dependencies

Feb 09, 2022
4 usages
Sep 21, 2021
5 usages
May 10, 2023
4 usages
0 stars
iap
Oct 21, 2021
4 usages
0 stars
Feb 12, 2023
4 usages
120 stars
Jul 12, 2023
6 usages
5.9k stars
Jul 12, 2023
6 usages
5.9k stars
Jul 12, 2023
6 usages
5.9k stars
Jul 12, 2023
6 usages
5.9k stars
Jul 12, 2023
6 usages
5.9k stars