config

Documentation

Index

• func GetBootstrapServers(ctx *pulumi.Context) string
• func GetCaCert(ctx *pulumi.Context) string
• func GetCaCertFile(ctx *pulumi.Context) string
• func GetClientCert(ctx *pulumi.Context) string
• func GetClientCertFile(ctx *pulumi.Context) string
• func GetClientKey(ctx *pulumi.Context) string
• func GetClientKeyFile(ctx *pulumi.Context) string
• func GetClientKeyPassphrase(ctx *pulumi.Context) string
• func GetSaslMechanism(ctx *pulumi.Context) string
• func GetSaslPassword(ctx *pulumi.Context) string
• func GetSaslUsername(ctx *pulumi.Context) string
• func GetSkipTlsVerify(ctx *pulumi.Context) bool
• func GetTimeout(ctx *pulumi.Context) int
• func GetTlsEnabled(ctx *pulumi.Context) bool
• func PkgVersion() (semver.Version, error)

Functions

func GetBootstrapServers

func GetBootstrapServers(ctx *pulumi.Context) string

A list of kafka brokers

func GetCaCert

func GetCaCert(ctx *pulumi.Context) string

CA certificate file to validate the server's certificate.

func GetCaCertFile

func GetCaCertFile(ctx *pulumi.Context) string

Path to a CA certificate file to validate the server's certificate.

Deprecated: This parameter is now deprecated and will be removed in a later release, please use `ca_cert` instead.

func GetClientCert

func GetClientCert(ctx *pulumi.Context) string

The client certificate.

func GetClientCertFile

func GetClientCertFile(ctx *pulumi.Context) string

Path to a file containing the client certificate.

Deprecated: This parameter is now deprecated and will be removed in a later release, please use `client_cert` instead.

func GetClientKey

func GetClientKey(ctx *pulumi.Context) string

The private key that the certificate was issued for.

func GetClientKeyFile

func GetClientKeyFile(ctx *pulumi.Context) string

Path to a file containing the private key that the certificate was issued for.

Deprecated: This parameter is now deprecated and will be removed in a later release, please use `client_key` instead.

func GetClientKeyPassphrase

func GetClientKeyPassphrase(ctx *pulumi.Context) string

The passphrase for the private key that the certificate was issued for.

func GetSaslMechanism

func GetSaslMechanism(ctx *pulumi.Context) string

SASL mechanism, can be plain, scram-sha512, scram-sha256

func GetSaslPassword

func GetSaslPassword(ctx *pulumi.Context) string

Password for SASL authentication.

func GetSaslUsername

func GetSaslUsername(ctx *pulumi.Context) string

Username for SASL authentication.

func GetSkipTlsVerify

func GetSkipTlsVerify(ctx *pulumi.Context) bool

Set this to true only if the target Kafka server is an insecure development instance.

func GetTimeout

func GetTimeout(ctx *pulumi.Context) int

Timeout in seconds

func GetTlsEnabled

func GetTlsEnabled(ctx *pulumi.Context) bool

Enable communication with the Kafka Cluster over TLS.

func PkgVersion

func PkgVersion() (semver.Version, error)

PkgVersion uses reflection to determine the version of the current package.