public class S3TierObjectStoreConfig extends TierObjectStoreConfig
Modifier and Type | Field and Description |
---|---|
Optional<String> |
assumeRoleArn |
Integer |
s3AutoAbortThresholdBytes |
String |
s3Bucket |
Optional<String> |
s3CredFilePath |
Optional<String> |
s3EndpointOverride |
Boolean |
s3ForcePathStyleAccess |
String |
s3Prefix |
String |
s3Region |
Optional<String> |
s3SignerOverride |
String |
s3SseAlgorithm |
String |
s3SseCustomerEncryptionKey |
String |
s3UserAgentPrefix |
brokerIdOpt, clusterIdOpt
Modifier | Constructor and Description |
---|---|
|
S3TierObjectStoreConfig(Optional<String> clusterIdOpt,
kafka.server.KafkaConfig config) |
protected |
S3TierObjectStoreConfig(Optional<String> clusterIdOpt,
Optional<Integer> brokerIdOpt,
String bucket,
String region,
String credFilePath,
String endpointOverride,
String signerOverride,
String sseAlgorithm,
String s3SseCustomerEncryptionKey,
Integer s3AutoAbortThresholdBytes,
String s3Prefix,
String assumeRoleArn,
Boolean s3ForcePathStyleAccess,
String s3UserAgentPrefix) |
public String s3Bucket
public String s3Region
public String s3Prefix
public String s3SseAlgorithm
public String s3SseCustomerEncryptionKey
public Integer s3AutoAbortThresholdBytes
public Boolean s3ForcePathStyleAccess
public String s3UserAgentPrefix
public S3TierObjectStoreConfig(Optional<String> clusterIdOpt, kafka.server.KafkaConfig config)
protected S3TierObjectStoreConfig(Optional<String> clusterIdOpt, Optional<Integer> brokerIdOpt, String bucket, String region, String credFilePath, String endpointOverride, String signerOverride, String sseAlgorithm, String s3SseCustomerEncryptionKey, Integer s3AutoAbortThresholdBytes, String s3Prefix, String assumeRoleArn, Boolean s3ForcePathStyleAccess, String s3UserAgentPrefix)