kafka RemotePartitionMetadataEventHandler 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemotePartitionMetadataEventHandler.java
阅读全文
kafka RemoteLogSegmentMetadataSnapshot 源码
kafka RemoteLogSegmentMetadataSnapshot 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogSegmentMetadataSnapshot.java
阅读全文
kafka RemoteLogMetadataTopicPartitioner 源码
kafka RemoteLogMetadataTopicPartitioner 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataTopicPartitioner.java
阅读全文
kafka RemoteLogMetadataSnapshotFile 源码
kafka RemoteLogMetadataSnapshotFile 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java
阅读全文
kafka RemoteLogMetadataCache 源码
kafka RemoteLogMetadataCache 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataCache.java
阅读全文
kafka RemoteLogLeaderEpochState 源码
kafka RemoteLogLeaderEpochState 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogLeaderEpochState.java
阅读全文
kafka ProducerManager 源码
kafka ProducerManager 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ProducerManager.java
阅读全文
kafka FileBasedRemoteLogMetadataCache 源码
kafka FileBasedRemoteLogMetadataCache 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/FileBasedRemoteLogMetadataCache.java
阅读全文
kafka ConsumerTask 源码
kafka ConsumerTask 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java
阅读全文
kafka ConsumerManager 源码
kafka ConsumerManager 代码
文件路径:/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerManager.java
阅读全文