Versions in this module Expand all Collapse all v2 v2.2.1 Oct 19, 2020 Changes in this version + type Container struct + func (c *Container) Kill() error + func (c *Container) RunningKafka() bool + func (c *Container) Start() error + func (c *Container) Stop() error + type KafkaCluster struct + func NewKafkaCluster(kafkaDockerDir string, size int) *KafkaCluster + func (cluster *KafkaCluster) ContainerKill(containerID string) error + func (cluster *KafkaCluster) ContainerNetworkIP(container Container, network string) (string, error) + func (cluster *KafkaCluster) ContainerStart(containerID string) error + func (cluster *KafkaCluster) ContainerStop(containerID string) error + func (cluster *KafkaCluster) Containers() ([]*Container, error) + func (cluster *KafkaCluster) KafkaAddrs() ([]string, error) + func (cluster *KafkaCluster) Start() error + func (cluster *KafkaCluster) Stop() error + func (cluster *KafkaCluster) WaitUntilReady() error