public class TierObjectStoreUtils extends Object
Modifier and Type | Field and Description |
---|---|
static List<String> |
OBJECT_STORE_REQUIRED_PROPERTIES |
Constructor and Description |
---|
TierObjectStoreUtils() |
Modifier and Type | Method and Description |
---|---|
static TierObjectStoreConfig |
generateBackendConfig(TierObjectStore.Backend backend,
Properties props)
This method generates the TierStoreConfig for the various backends.
|
static Optional<TierObjectStore> |
maybeCreateTierObjectStore(kafka.server.KafkaConfig config,
String clusterId,
org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time,
Optional<io.confluent.kafka.storage.checksum.E2EChecksumStore> checksumStoreOpt) |
static TierObjectStore |
objectStore(String objectStoreConfigFile)
Get a reference to the object store
|
static void |
postPutSegmentCleanup(io.confluent.kafka.storage.checksum.E2EChecksumStore checksumStore,
File segmentData,
File offsetIndexData,
File timestampIndexData) |
static ByteBuffer |
timeHealthPayload() |
public static Optional<TierObjectStore> maybeCreateTierObjectStore(kafka.server.KafkaConfig config, String clusterId, org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time, Optional<io.confluent.kafka.storage.checksum.E2EChecksumStore> checksumStoreOpt)
public static TierObjectStoreConfig generateBackendConfig(TierObjectStore.Backend backend, Properties props)
backend
- The backend for which the config will be generatedprops
- The Properties object for creating the backendpublic static TierObjectStore objectStore(String objectStoreConfigFile) throws IOException
objectStoreConfigFile
- configurations required to validate access to the object store.IOException
- If any IOException occurspublic static ByteBuffer timeHealthPayload()