kafka

May 9, 2023

Changes in this version

+ type Option interface

+ 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 struct

+ Ports []string

+ SchemaRegistryURL string

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

+ func (k *Resource) Destroy() error

+ type SASLConfig struct

+ BrokerUser User

+ CertificatePassword string

+ KeyStorePath string

+ TrustStorePath string

+ Users []User

+ type User struct

+ Password string

+ Username string