Struct KafkaConnection

pub struct KafkaConnection {

    pub brokers: String,
    security_protocol: Option<String>,
    ssl_endpoint_identification_algorithm: Option<String>,
    ssl_ca_location: Option<String>,
    ssl_ca_pem: Option<String>,
    ssl_certificate_location: Option<String>,
    ssl_certificate_pem: Option<String>,
    ssl_key_location: Option<String>,
    ssl_key_pem: Option<String>,
    ssl_key_password: Option<String>,
    sasl_mechanism: Option<String>,
    sasl_username: Option<String>,
    sasl_password: Option<String>,
    sasl_kerberos_service_name: Option<String>,
    sasl_kerberos_keytab: Option<String>,
    sasl_kerberos_principal: Option<String>,
    sasl_kerberos_kinit_cmd: Option<String>,
    sasl_kerberos_min_time_before_relogin: Option<String>,
    sasl_oathbearer_config: Option<String>,
}

Fields

brokers: String

security_protocol: Option<String>

Security protocol used for RisingWave to communicate with Kafka brokers. Could be PLAINTEXT, SSL, SASL_PLAINTEXT or SASL_SSL.

ssl_endpoint_identification_algorithm: Option<String>

ssl_ca_location: Option<String>

Path to CA certificate file for verifying the broker’s key.

ssl_ca_pem: Option<String>

CA certificate string (PEM format) for verifying the broker’s key.

ssl_certificate_location: Option<String>

Path to client’s certificate file (PEM).

ssl_certificate_pem: Option<String>

Client’s public key string (PEM format) used for authentication.

ssl_key_location: Option<String>

Path to client’s private key file (PEM).

ssl_key_pem: Option<String>

Client’s private key string (PEM format) used for authentication.

ssl_key_password: Option<String>

Passphrase of client’s private key.

sasl_mechanism: Option<String>

SASL mechanism if SASL is enabled. Currently support PLAIN, SCRAM, GSSAPI, and AWS_MSK_IAM.

sasl_username: Option<String>

SASL username for SASL/PLAIN and SASL/SCRAM.

sasl_password: Option<String>

SASL password for SASL/PLAIN and SASL/SCRAM.

sasl_kerberos_service_name: Option<String>

Kafka server’s Kerberos principal name under SASL/GSSAPI, not including /hostname@REALM.

sasl_kerberos_keytab: Option<String>

Path to client’s Kerberos keytab file under SASL/GSSAPI.

sasl_kerberos_principal: Option<String>

Client’s Kerberos principal name under SASL/GSSAPI.

sasl_kerberos_kinit_cmd: Option<String>

Shell command to refresh or acquire the client’s Kerberos ticket under SASL/GSSAPI.

sasl_kerberos_min_time_before_relogin: Option<String>

Minimum time in milliseconds between key refresh attempts under SASL/GSSAPI.

sasl_oathbearer_config: Option<String>

Configurations for SASL/OAUTHBEARER.

Implementations

impl KafkaConnection

pub(crate) fn set_security_properties(&self, config: &mut ClientConfig)

pub(crate) fn is_aws_msk_iam(&self) -> bool

Trait Implementations

impl Clone for KafkaConnection

fn clone(&self) -> KafkaConnection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KafkaConnection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for KafkaConnection

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for KafkaConnection

fn eq(&self, other: &KafkaConnection) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for KafkaConnection

impl StructuralPartialEq for KafkaConnection

impl WithOptions for KafkaConnection