Package com.dtsx.astra.sdk.db.domain.telemetry

Class KafkaTelemetryRequest

java.lang.Object
com.dtsx.astra.sdk.db.domain.telemetry.KafkaTelemetryRequest
public class KafkaTelemetryRequest extends Object
Pojo to setup Telemetry with Astra and Kafka.

  • Constructor Details

    • KafkaTelemetryRequest

      public KafkaTelemetryRequest()
      Default Constructor.

    • KafkaTelemetryRequest

      public KafkaTelemetryRequest(Set<String> bootstrapServers, String topic, String sasl_mechanism, String sasl_username, String sasl_password, String security_protocol)
      Full Constructor.
      Parameters:
      bootstrapServers - bootstraps
      topic - topic
      sasl_mechanism - mechanism
      sasl_username - username
      sasl_password - password
      security_protocol - protocol

  • Method Details

    • setSaslMechanism

      public void setSaslMechanism(String saslMechanism)
      Set value for saslMechanism
      Parameters:
      saslMechanism - new value for saslMechanism

    • setSaslUsername

      public void setSaslUsername(String saslUsername)
      Set value for saslUsername
      Parameters:
      saslUsername - new value for saslUsername

    • setSaslPassword

      public void setSaslPassword(String saslPassword)
      Set value for saslPassword
      Parameters:
      saslPassword - new value for saslPassword

    • getSaslMechanism

      public String getSaslMechanism()
      Gets saslMechanism
      Returns:
      value of saslMechanism

    • getSaslUsername

      public String getSaslUsername()
      Gets saslUsername
      Returns:
      value of saslUsername

    • getSaslPassword

      public String getSaslPassword()
      Gets saslPassword
      Returns:
      value of saslPassword

    • setBootstrapServers

      public void setBootstrapServers(Set<String> bootstrapServers)
      Set value for bootstrapServers
      Parameters:
      bootstrapServers - new value for bootstrapServers

    • setTopic

      public void setTopic(String topic)
      Set value for topic
      Parameters:
      topic - new value for topic

    • setSecurity_protocol

      public void setSecurity_protocol(String security_protocol)
      Set value for security_protocol
      Parameters:
      security_protocol - new value for security_protocol

    • getBootstrapServers

      public Set<String> getBootstrapServers()
      Gets bootstrapServers
      Returns:
      value of bootstrapServers

    • getTopic

      public String getTopic()
      Gets topic
      Returns:
      value of topic

    • getSecurity_protocol

      public String getSecurity_protocol()
      Gets security_protocol
      Returns:
      value of security_protocol