kafka

type Consumer struct {
	// contains filtered or unexported fields
}

type Interface interface {
	Consume(topic string, listener func(delivery []byte) error) (err error)
	Publish(topic string, key string, payload []byte) error
	Close()
	EnsureTopic(bootstrapUrl string, topic string, config map[string]string) (err error)
}

type Kafka struct {
	// contains filtered or unexported fields
}

type Publisher struct {
	// contains filtered or unexported fields
}