kafka

Documentation

Index

• type Option
  • func WithBrokers(noOfBrokers uint) Option
  • func WithCustomAdvertisedListener(listener string) Option
  • func WithLogger(l destination.Logger) Option
  • func WithNetwork(network *dc.Network) Option
  • func WithSASLPlain(conf *SASLConfig) Option
  • func WithSASLScramSHA256(conf *SASLConfig) Option
  • func WithSASLScramSHA512(conf *SASLConfig) Option
  • func WithSchemaRegistry() Option
  • func WithoutDockerHostListeners() Option
• type Resource
  • func Setup(pool *dockertest.Pool, cln destination.Cleaner, opts ...Option) (*Resource, error)
  • func (k *Resource) Destroy() error
• type SASLConfig
• type User

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
}