Versions in this module Expand all Collapse all v1 v1.1.0 Dec 19, 2019 v1.0.0 Dec 19, 2019 Changes in this version + var ErrDisabled = fmt.Errorf("kafka tests are disabled") + type Kafka struct + func New() (*Kafka, error) + func (k *Kafka) Addrs() []string + func (k *Kafka) Close() error + func (k *Kafka) Config() *sarama.Config + func (k *Kafka) InitConfig(cfg *sarama.Config) + func (k *Kafka) NewTopic() string
Go to main page