getObjectStoreInstance
public static TierObjectStore getObjectStoreInstance(org.apache.kafka.common.utils.Time time,
TierObjectStore.Backend backend,
TierObjectStoreConfig config)
This method will instantiate the necessary backend store instance and then return the same instance for
consecutive requests.
Note: Users can use TierObjectStoreUtils.generateBackendConfig for creating the necessary config
The synchronization is necessary for the singleton pattern.
This method also throws IllegalArgumentException for various illegal/unsupported backend args
- Parameters:
backend
- The backend enum for which an instance is required
config
- The object store config. Can use TierObjectStoreUtils.generateBackendConfig for generation
- Returns:
- The TierObjectStore instance