Expand description
Kafka Backup Core Library
This crate provides the core functionality for backing up and restoring Kafka topics to/from various storage backends.
Re-exports§
pub use circuit_breaker::CircuitBreaker;pub use circuit_breaker::CircuitBreakerConfig;pub use circuit_breaker::CircuitState;pub use config::Config;pub use config::MetricsConfig;pub use config::OffsetStorageBackend;pub use config::OffsetStorageConfig;pub use config::OffsetStrategy;pub use config::RestoreOptions;pub use error::Error;pub use error::Result;pub use health::HealthCheck;pub use health::HealthStatus;pub use kafka::CommittedOffset;pub use kafka::ConsumerGroup;pub use kafka::ConsumerGroupDescription;pub use kafka::ConsumerGroupMember;pub use kafka::TimestampOffset;pub use manifest::BackupManifest;pub use manifest::BackupRecord;pub use manifest::ConsumerGroupOffset;pub use manifest::ConsumerGroupOffsets;pub use manifest::DryRunPartitionReport;pub use manifest::DryRunReport;pub use manifest::DryRunTopicReport;pub use manifest::OffsetMapping;pub use manifest::OffsetMappingEntry;pub use manifest::OffsetPair;pub use manifest::PartitionBackup;pub use manifest::PartitionRestoreReport;pub use manifest::RecordHeader;pub use manifest::RestoreCheckpoint;pub use manifest::RestoreReport;pub use manifest::SegmentMetadata;pub use manifest::TopicBackup;pub use manifest::TopicRestoreReport;pub use metrics::create_instrumented_backend;pub use metrics::ErrorType;pub use metrics::InstrumentedStorageBackend;pub use metrics::MetricsReport;pub use metrics::MetricsServer;pub use metrics::MetricsServerConfig;pub use metrics::OperationStatus;pub use metrics::PerformanceMetrics;pub use metrics::PrometheusMetrics;pub use metrics::StorageOperation;pub use metrics::TimerGuard;pub use offset_store::OffsetStore;pub use offset_store::OffsetStoreConfig;pub use offset_store::SqliteOffsetStore;pub use restore::engine::RestoreEngine;pub use restore::engine::RestoreProgress;pub use restore::offset_automation::BulkOffsetReset;pub use restore::offset_automation::BulkOffsetResetConfig;pub use restore::offset_automation::BulkOffsetResetReport;pub use restore::offset_automation::BulkResetStatus;pub use restore::offset_automation::GroupResetOutcome;pub use restore::offset_automation::OffsetMapping as BulkOffsetMapping;pub use restore::offset_automation::OffsetResetBatch;pub use restore::offset_automation::OffsetResetMetrics;pub use restore::offset_automation::PartitionError;pub use restore::offset_automation::PerformanceStats;pub use restore::offset_reset::GroupResetPlan;pub use restore::offset_reset::GroupResetResult;pub use restore::offset_reset::OffsetResetExecutor;pub use restore::offset_reset::OffsetResetPlan;pub use restore::offset_reset::OffsetResetPlanBuilder;pub use restore::offset_reset::OffsetResetReport;pub use restore::offset_reset::OffsetResetStrategy;pub use restore::offset_reset::PartitionResetPlan;pub use restore::offset_rollback::reset_offsets_with_rollback;pub use restore::offset_rollback::rollback_offset_reset;pub use restore::offset_rollback::snapshot_current_offsets;pub use restore::offset_rollback::verify_rollback;pub use restore::offset_rollback::GroupOffsetState;pub use restore::offset_rollback::OffsetMismatch;pub use restore::offset_rollback::OffsetSnapshot;pub use restore::offset_rollback::OffsetSnapshotMetadata;pub use restore::offset_rollback::OffsetSnapshotStorage;pub use restore::offset_rollback::PartitionOffsetState;pub use restore::offset_rollback::RestoreWithRollbackResult;pub use restore::offset_rollback::RestoreWithRollbackStatus;pub use restore::offset_rollback::RollbackResult;pub use restore::offset_rollback::RollbackStatus;pub use restore::offset_rollback::StorageBackendSnapshotStore;pub use restore::offset_rollback::VerificationResult;pub use restore::three_phase::Phase1ValidationReport;pub use restore::three_phase::ThreePhaseReport;pub use restore::three_phase::ThreePhaseRestore;
Modules§
- backup
- Backup engine module.
- circuit_
breaker - Circuit breaker pattern for fault tolerance.
- compression
- Compression utilities for backup segments.
- config
- Configuration structures for Kafka backup and restore operations.
- error
- Error types for the Kafka backup core library.
- health
- Health monitoring for backup/restore processes.
- kafka
- Kafka protocol client implementation.
- manifest
- Backup manifest and record structures.
- metrics
- Performance metrics collection and reporting.
- offset_
store - Offset storage for tracking backup progress.
- restore
- Restore engine module.
- segment
- Binary segment format for efficient backup storage.
- storage
- Storage backend abstraction and implementations.