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