public class AzureBlockBlobTierObjectStoreConfig extends TierObjectStoreConfig
Modifier and Type | Field and Description |
---|---|
String |
azureBlobPrefix |
Optional<kafka.tier.store.AzureBlockBlobTierObjectStoreConfig.AzureCredentialsConfig> |
azureCredentialsConfig |
String |
container |
int |
drainThreshold |
Optional<String> |
endpoint |
brokerIdOpt, clusterIdOpt
Modifier | Constructor and Description |
---|---|
|
AzureBlockBlobTierObjectStoreConfig(Optional<String> clusterIdOpt,
kafka.server.KafkaConfig config) |
protected |
AzureBlockBlobTierObjectStoreConfig(Optional<String> clusterIdOpt,
Optional<Integer> brokerIdOpt,
Optional<String> azureBlockBlobCredFilePath,
Optional<String> endpoint,
String container,
String azureBlobPrefix,
int drainThreshold) |
Modifier and Type | Method and Description |
---|---|
static AzureBlockBlobTierObjectStoreConfig |
createWithEmptyClusterIdBrokerId(Optional<String> azureBlockBlobCredFilePath,
Optional<String> endpoint,
String container,
String azureBlobPrefix,
int drainThreshold) |
public Optional<kafka.tier.store.AzureBlockBlobTierObjectStoreConfig.AzureCredentialsConfig> azureCredentialsConfig
public String container
public String azureBlobPrefix
public int drainThreshold