kafka

package
v1.9.0-rc.2 Latest Latest
Warning

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

Go to latest
Published: May 19, 2023 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithBrokers

func WithBrokers(noOfBrokers uint) Option

WithBrokers allows to set the number of brokers in the cluster

func WithCustomAdvertisedListener

func WithCustomAdvertisedListener(listener string) Option

WithCustomAdvertisedListener allows to set a custom advertised listener

func WithLogger

func WithLogger(l destination.Logger) Option

WithLogger allows to set a logger that prints debugging information

func WithNetwork

func WithNetwork(network *dc.Network) Option

WithNetwork allows to set a docker network to use for the cluster

func WithSASLPlain

func WithSASLPlain(conf *SASLConfig) Option

WithSASLPlain is used to configure SASL authentication (PLAIN)

func WithSASLScramSHA256

func WithSASLScramSHA256(conf *SASLConfig) Option

WithSASLScramSHA256 is used to configure SASL authentication (Scram SHA-256)

func WithSASLScramSHA512

func WithSASLScramSHA512(conf *SASLConfig) Option

WithSASLScramSHA512 is used to configure SASL authentication (Scram SHA-512)

func WithSchemaRegistry

func WithSchemaRegistry() Option

WithSchemaRegistry allows to use the schema registry

func WithoutDockerHostListeners

func WithoutDockerHostListeners() Option

WithoutDockerHostListeners allows to not set the advertised listener to the host mapped port

type Resource

type Resource struct {
	Ports             []string
	SchemaRegistryURL string
	// contains filtered or unexported fields
}

func Setup

func Setup(pool *dockertest.Pool, cln destination.Cleaner, opts ...Option) (*Resource, error)

func (*Resource) Destroy

func (k *Resource) Destroy() error

type SASLConfig

type SASLConfig struct {
	BrokerUser                   User
	Users                        []User
	CertificatePassword          string
	KeyStorePath, TrustStorePath string
	// contains filtered or unexported fields
}

type User

type User struct {
	Username, Password string
}

Jump to

Keyboard shortcuts

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