testing

Documentation

Index

• func KafkaIsAtLeast(semver string) bool
• type ConnWaitGroup
  • func (g *ConnWaitGroup) Dial(ctx context.Context, network, address string) (net.Conn, error)

Functions

func KafkaIsAtLeast

func KafkaIsAtLeast(semver string) bool

KafkaIsAtLeast returns true when the test broker is running a protocol version that is semver or newer. It determines the broker's version using the `KAFKA_VERSION` environment variable. If the var is unset, then this function will return true.

Types

type ConnWaitGroup

type ConnWaitGroup struct {
	DialFunc func(context.Context, string, string) (net.Conn, error)
	sync.WaitGroup
}

func (*ConnWaitGroup) Dial

func (g *ConnWaitGroup) Dial(ctx context.Context, network, address string) (net.Conn, error)