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 |
List<String> |
s3SslEnabledProtocols |
Optional<org.apache.kafka.common.config.types.Password> |
s3SslKeyPassword |
Optional<String> |
s3SslKeyStoreLocation |
Optional<org.apache.kafka.common.config.types.Password> |
s3SslKeyStorePassword |
Optional<String> |
s3SslKeyStoreType |
String |
s3SslProtocol |
Optional<String> |
s3SslTrustStoreLocation |
Optional<org.apache.kafka.common.config.types.Password> |
s3SslTrustStorePassword |
Optional<String> |
s3SslTrustStoreType |
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,
String sslProtocol,
String sslEnabledProtocols,
String sslTrustStoreLocation,
org.apache.kafka.common.config.types.Password sslTrustStorePassword,
String sslTrustStoreType,
String sslKeyStoreLocation,
org.apache.kafka.common.config.types.Password sslKeyStorePassword,
String sslKeyStoreType,
org.apache.kafka.common.config.types.Password sslKeyPassword) |
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 String s3SslProtocol
public Optional<org.apache.kafka.common.config.types.Password> s3SslTrustStorePassword
public Optional<org.apache.kafka.common.config.types.Password> s3SslKeyStorePassword
public Optional<org.apache.kafka.common.config.types.Password> s3SslKeyPassword
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, String sslProtocol, String sslEnabledProtocols, String sslTrustStoreLocation, org.apache.kafka.common.config.types.Password sslTrustStorePassword, String sslTrustStoreType, String sslKeyStoreLocation, org.apache.kafka.common.config.types.Password sslKeyStorePassword, String sslKeyStoreType, org.apache.kafka.common.config.types.Password sslKeyPassword)