producer

type Delivery struct {
	TopicPartition kafkamod.TopicPartition
	Error          error
}

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

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

type Options struct {
	Configs map[string]interface{}
}

type Producer interface {
	Produce(msg kafkamod.Message) error
	Delivery(chDelivery chan Delivery)
	Flush(timeoutMs int) int
	Close()
}