kafka

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 12, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAdminClient

func NewAdminClient(ctx context.Context, data []byte, kube client.Client) (*kadm.Client, error)

NewAdminClient creates a new AdminClient with supplied credentials

Types

type ClientCertificateSecretRef added in v0.2.0

type ClientCertificateSecretRef struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	KeyField  string `json:"keyField,omitempty"`
	CertField string `json:"certField,omitempty"`
}

ClientCertificateSecretRef is a TLS option for enable mTLS

type Config

type Config struct {
	Brokers []string `json:"brokers"`
	SASL    *SASL    `json:"sasl,omitempty"`
	TLS     *TLS     `json:"tls,omitempty"`
}

Config is a Kafka client configuration

type SASL

type SASL struct {
	Mechanism string `json:"mechanism"`
	Username  string `json:"username"`
	Password  string `json:"password"`
}

SASL is an sasl option

type TLS added in v0.2.0

type TLS struct {
	ClientCertificateSecretRef *ClientCertificateSecretRef `json:"clientCertificateSecretRef,omitempty"`
	InsecureSkipVerify         bool                        `json:"insecureSkipVerify"`
}

TLS is an option for enabling encryption in transit

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL