KafkaSettings.h

 
#pragma once
#include <aws/core/utils/memory/stl/AWSString.h>
#include <aws/dms/DatabaseMigrationService_EXPORTS.h>
#include <aws/dms/model/KafkaSaslMechanism.h>
#include <aws/dms/model/KafkaSecurityProtocol.h>
#include <aws/dms/model/KafkaSslEndpointIdentificationAlgorithm.h>
#include <aws/dms/model/MessageFormatValue.h>
 
#include <utility>
 
namespace Aws {
namespace Utils {
namespace Json {
class JsonValue;
class JsonView;
}  // namespace Json
}  // namespace Utils
namespace DatabaseMigrationService {
namespace Model {
 
class KafkaSettings {
 public:
  AWS_DATABASEMIGRATIONSERVICE_API KafkaSettings() = default;
  AWS_DATABASEMIGRATIONSERVICE_API KafkaSettings(Aws::Utils::Json::JsonView jsonValue);
  AWS_DATABASEMIGRATIONSERVICE_API KafkaSettings& operator=(Aws::Utils::Json::JsonView jsonValue);
  AWS_DATABASEMIGRATIONSERVICE_API Aws::Utils::Json::JsonValue Jsonize() const;
 
 
  inline const Aws::String& GetBroker() const { return m_broker; }
  inline bool BrokerHasBeenSet() const { return m_brokerHasBeenSet; }
  template <typename BrokerT = Aws::String>
  void SetBroker(BrokerT&& value) {
    m_brokerHasBeenSet = true;
    m_broker = std::forward<BrokerT>(value);
  }
  template <typename BrokerT = Aws::String>
  KafkaSettings& WithBroker(BrokerT&& value) {
    SetBroker(std::forward<BrokerT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetTopic() const { return m_topic; }
  inline bool TopicHasBeenSet() const { return m_topicHasBeenSet; }
  template <typename TopicT = Aws::String>
  void SetTopic(TopicT&& value) {
    m_topicHasBeenSet = true;
    m_topic = std::forward<TopicT>(value);
  }
  template <typename TopicT = Aws::String>
  KafkaSettings& WithTopic(TopicT&& value) {
    SetTopic(std::forward<TopicT>(value));
    return *this;
  }
 
 
  inline MessageFormatValue GetMessageFormat() const { return m_messageFormat; }
  inline bool MessageFormatHasBeenSet() const { return m_messageFormatHasBeenSet; }
  inline void SetMessageFormat(MessageFormatValue value) {
    m_messageFormatHasBeenSet = true;
    m_messageFormat = value;
  }
  inline KafkaSettings& WithMessageFormat(MessageFormatValue value) {
    SetMessageFormat(value);
    return *this;
  }
 
 
  inline bool GetIncludeTransactionDetails() const { return m_includeTransactionDetails; }
  inline bool IncludeTransactionDetailsHasBeenSet() const { return m_includeTransactionDetailsHasBeenSet; }
  inline void SetIncludeTransactionDetails(bool value) {
    m_includeTransactionDetailsHasBeenSet = true;
    m_includeTransactionDetails = value;
  }
  inline KafkaSettings& WithIncludeTransactionDetails(bool value) {
    SetIncludeTransactionDetails(value);
    return *this;
  }
 
 
  inline bool GetIncludePartitionValue() const { return m_includePartitionValue; }
  inline bool IncludePartitionValueHasBeenSet() const { return m_includePartitionValueHasBeenSet; }
  inline void SetIncludePartitionValue(bool value) {
    m_includePartitionValueHasBeenSet = true;
    m_includePartitionValue = value;
  }
  inline KafkaSettings& WithIncludePartitionValue(bool value) {
    SetIncludePartitionValue(value);
    return *this;
  }
 
 
  inline bool GetPartitionIncludeSchemaTable() const { return m_partitionIncludeSchemaTable; }
  inline bool PartitionIncludeSchemaTableHasBeenSet() const { return m_partitionIncludeSchemaTableHasBeenSet; }
  inline void SetPartitionIncludeSchemaTable(bool value) {
    m_partitionIncludeSchemaTableHasBeenSet = true;
    m_partitionIncludeSchemaTable = value;
  }
  inline KafkaSettings& WithPartitionIncludeSchemaTable(bool value) {
    SetPartitionIncludeSchemaTable(value);
    return *this;
  }
 
 
  inline bool GetIncludeTableAlterOperations() const { return m_includeTableAlterOperations; }
  inline bool IncludeTableAlterOperationsHasBeenSet() const { return m_includeTableAlterOperationsHasBeenSet; }
  inline void SetIncludeTableAlterOperations(bool value) {
    m_includeTableAlterOperationsHasBeenSet = true;
    m_includeTableAlterOperations = value;
  }
  inline KafkaSettings& WithIncludeTableAlterOperations(bool value) {
    SetIncludeTableAlterOperations(value);
    return *this;
  }
 
 
  inline bool GetIncludeControlDetails() const { return m_includeControlDetails; }
  inline bool IncludeControlDetailsHasBeenSet() const { return m_includeControlDetailsHasBeenSet; }
  inline void SetIncludeControlDetails(bool value) {
    m_includeControlDetailsHasBeenSet = true;
    m_includeControlDetails = value;
  }
  inline KafkaSettings& WithIncludeControlDetails(bool value) {
    SetIncludeControlDetails(value);
    return *this;
  }
 
 
  inline int GetMessageMaxBytes() const { return m_messageMaxBytes; }
  inline bool MessageMaxBytesHasBeenSet() const { return m_messageMaxBytesHasBeenSet; }
  inline void SetMessageMaxBytes(int value) {
    m_messageMaxBytesHasBeenSet = true;
    m_messageMaxBytes = value;
  }
  inline KafkaSettings& WithMessageMaxBytes(int value) {
    SetMessageMaxBytes(value);
    return *this;
  }
 
 
  inline bool GetIncludeNullAndEmpty() const { return m_includeNullAndEmpty; }
  inline bool IncludeNullAndEmptyHasBeenSet() const { return m_includeNullAndEmptyHasBeenSet; }
  inline void SetIncludeNullAndEmpty(bool value) {
    m_includeNullAndEmptyHasBeenSet = true;
    m_includeNullAndEmpty = value;
  }
  inline KafkaSettings& WithIncludeNullAndEmpty(bool value) {
    SetIncludeNullAndEmpty(value);
    return *this;
  }
 
 
  inline KafkaSecurityProtocol GetSecurityProtocol() const { return m_securityProtocol; }
  inline bool SecurityProtocolHasBeenSet() const { return m_securityProtocolHasBeenSet; }
  inline void SetSecurityProtocol(KafkaSecurityProtocol value) {
    m_securityProtocolHasBeenSet = true;
    m_securityProtocol = value;
  }
  inline KafkaSettings& WithSecurityProtocol(KafkaSecurityProtocol value) {
    SetSecurityProtocol(value);
    return *this;
  }
 
 
  inline const Aws::String& GetSslClientCertificateArn() const { return m_sslClientCertificateArn; }
  inline bool SslClientCertificateArnHasBeenSet() const { return m_sslClientCertificateArnHasBeenSet; }
  template <typename SslClientCertificateArnT = Aws::String>
  void SetSslClientCertificateArn(SslClientCertificateArnT&& value) {
    m_sslClientCertificateArnHasBeenSet = true;
    m_sslClientCertificateArn = std::forward<SslClientCertificateArnT>(value);
  }
  template <typename SslClientCertificateArnT = Aws::String>
  KafkaSettings& WithSslClientCertificateArn(SslClientCertificateArnT&& value) {
    SetSslClientCertificateArn(std::forward<SslClientCertificateArnT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetSslClientKeyArn() const { return m_sslClientKeyArn; }
  inline bool SslClientKeyArnHasBeenSet() const { return m_sslClientKeyArnHasBeenSet; }
  template <typename SslClientKeyArnT = Aws::String>
  void SetSslClientKeyArn(SslClientKeyArnT&& value) {
    m_sslClientKeyArnHasBeenSet = true;
    m_sslClientKeyArn = std::forward<SslClientKeyArnT>(value);
  }
  template <typename SslClientKeyArnT = Aws::String>
  KafkaSettings& WithSslClientKeyArn(SslClientKeyArnT&& value) {
    SetSslClientKeyArn(std::forward<SslClientKeyArnT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetSslClientKeyPassword() const { return m_sslClientKeyPassword; }
  inline bool SslClientKeyPasswordHasBeenSet() const { return m_sslClientKeyPasswordHasBeenSet; }
  template <typename SslClientKeyPasswordT = Aws::String>
  void SetSslClientKeyPassword(SslClientKeyPasswordT&& value) {
    m_sslClientKeyPasswordHasBeenSet = true;
    m_sslClientKeyPassword = std::forward<SslClientKeyPasswordT>(value);
  }
  template <typename SslClientKeyPasswordT = Aws::String>
  KafkaSettings& WithSslClientKeyPassword(SslClientKeyPasswordT&& value) {
    SetSslClientKeyPassword(std::forward<SslClientKeyPasswordT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetSslCaCertificateArn() const { return m_sslCaCertificateArn; }
  inline bool SslCaCertificateArnHasBeenSet() const { return m_sslCaCertificateArnHasBeenSet; }
  template <typename SslCaCertificateArnT = Aws::String>
  void SetSslCaCertificateArn(SslCaCertificateArnT&& value) {
    m_sslCaCertificateArnHasBeenSet = true;
    m_sslCaCertificateArn = std::forward<SslCaCertificateArnT>(value);
  }
  template <typename SslCaCertificateArnT = Aws::String>
  KafkaSettings& WithSslCaCertificateArn(SslCaCertificateArnT&& value) {
    SetSslCaCertificateArn(std::forward<SslCaCertificateArnT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetSaslUsername() const { return m_saslUsername; }
  inline bool SaslUsernameHasBeenSet() const { return m_saslUsernameHasBeenSet; }
  template <typename SaslUsernameT = Aws::String>
  void SetSaslUsername(SaslUsernameT&& value) {
    m_saslUsernameHasBeenSet = true;
    m_saslUsername = std::forward<SaslUsernameT>(value);
  }
  template <typename SaslUsernameT = Aws::String>
  KafkaSettings& WithSaslUsername(SaslUsernameT&& value) {
    SetSaslUsername(std::forward<SaslUsernameT>(value));
    return *this;
  }
 
 
  inline const Aws::String& GetSaslPassword() const { return m_saslPassword; }
  inline bool SaslPasswordHasBeenSet() const { return m_saslPasswordHasBeenSet; }
  template <typename SaslPasswordT = Aws::String>
  void SetSaslPassword(SaslPasswordT&& value) {
    m_saslPasswordHasBeenSet = true;
    m_saslPassword = std::forward<SaslPasswordT>(value);
  }
  template <typename SaslPasswordT = Aws::String>
  KafkaSettings& WithSaslPassword(SaslPasswordT&& value) {
    SetSaslPassword(std::forward<SaslPasswordT>(value));
    return *this;
  }
 
 
  inline bool GetNoHexPrefix() const { return m_noHexPrefix; }
  inline bool NoHexPrefixHasBeenSet() const { return m_noHexPrefixHasBeenSet; }
  inline void SetNoHexPrefix(bool value) {
    m_noHexPrefixHasBeenSet = true;
    m_noHexPrefix = value;
  }
  inline KafkaSettings& WithNoHexPrefix(bool value) {
    SetNoHexPrefix(value);
    return *this;
  }
 
 
  inline KafkaSaslMechanism GetSaslMechanism() const { return m_saslMechanism; }
  inline bool SaslMechanismHasBeenSet() const { return m_saslMechanismHasBeenSet; }
  inline void SetSaslMechanism(KafkaSaslMechanism value) {
    m_saslMechanismHasBeenSet = true;
    m_saslMechanism = value;
  }
  inline KafkaSettings& WithSaslMechanism(KafkaSaslMechanism value) {
    SetSaslMechanism(value);
    return *this;
  }
 
 
  inline KafkaSslEndpointIdentificationAlgorithm GetSslEndpointIdentificationAlgorithm() const {
    return m_sslEndpointIdentificationAlgorithm;
  }
  inline bool SslEndpointIdentificationAlgorithmHasBeenSet() const { return m_sslEndpointIdentificationAlgorithmHasBeenSet; }
  inline void SetSslEndpointIdentificationAlgorithm(KafkaSslEndpointIdentificationAlgorithm value) {
    m_sslEndpointIdentificationAlgorithmHasBeenSet = true;
    m_sslEndpointIdentificationAlgorithm = value;
  }
  inline KafkaSettings& WithSslEndpointIdentificationAlgorithm(KafkaSslEndpointIdentificationAlgorithm value) {
    SetSslEndpointIdentificationAlgorithm(value);
    return *this;
  }
 
 
  inline bool GetUseLargeIntegerValue() const { return m_useLargeIntegerValue; }
  inline bool UseLargeIntegerValueHasBeenSet() const { return m_useLargeIntegerValueHasBeenSet; }
  inline void SetUseLargeIntegerValue(bool value) {
    m_useLargeIntegerValueHasBeenSet = true;
    m_useLargeIntegerValue = value;
  }
  inline KafkaSettings& WithUseLargeIntegerValue(bool value) {
    SetUseLargeIntegerValue(value);
    return *this;
  }
 private:
  Aws::String m_broker;
 
  Aws::String m_topic;
 
  MessageFormatValue m_messageFormat{MessageFormatValue::NOT_SET};
 
  bool m_includeTransactionDetails{false};
 
  bool m_includePartitionValue{false};
 
  bool m_partitionIncludeSchemaTable{false};
 
  bool m_includeTableAlterOperations{false};
 
  bool m_includeControlDetails{false};
 
  int m_messageMaxBytes{0};
 
  bool m_includeNullAndEmpty{false};
 
  KafkaSecurityProtocol m_securityProtocol{KafkaSecurityProtocol::NOT_SET};
 
  Aws::String m_sslClientCertificateArn;
 
  Aws::String m_sslClientKeyArn;
 
  Aws::String m_sslClientKeyPassword;
 
  Aws::String m_sslCaCertificateArn;
 
  Aws::String m_saslUsername;
 
  Aws::String m_saslPassword;
 
  bool m_noHexPrefix{false};
 
  KafkaSaslMechanism m_saslMechanism{KafkaSaslMechanism::NOT_SET};
 
  KafkaSslEndpointIdentificationAlgorithm m_sslEndpointIdentificationAlgorithm{KafkaSslEndpointIdentificationAlgorithm::NOT_SET};
 
  bool m_useLargeIntegerValue{false};
  bool m_brokerHasBeenSet = false;
  bool m_topicHasBeenSet = false;
  bool m_messageFormatHasBeenSet = false;
  bool m_includeTransactionDetailsHasBeenSet = false;
  bool m_includePartitionValueHasBeenSet = false;
  bool m_partitionIncludeSchemaTableHasBeenSet = false;
  bool m_includeTableAlterOperationsHasBeenSet = false;
  bool m_includeControlDetailsHasBeenSet = false;
  bool m_messageMaxBytesHasBeenSet = false;
  bool m_includeNullAndEmptyHasBeenSet = false;
  bool m_securityProtocolHasBeenSet = false;
  bool m_sslClientCertificateArnHasBeenSet = false;
  bool m_sslClientKeyArnHasBeenSet = false;
  bool m_sslClientKeyPasswordHasBeenSet = false;
  bool m_sslCaCertificateArnHasBeenSet = false;
  bool m_saslUsernameHasBeenSet = false;
  bool m_saslPasswordHasBeenSet = false;
  bool m_noHexPrefixHasBeenSet = false;
  bool m_saslMechanismHasBeenSet = false;
  bool m_sslEndpointIdentificationAlgorithmHasBeenSet = false;
  bool m_useLargeIntegerValueHasBeenSet = false;
};
 
}  // namespace Model
}  // namespace DatabaseMigrationService
}  // namespace Aws