producer

type Producer interface {
	//Send sends a message to Kafka and returns an error if it fails.
	Send(topic string, key []byte, value []byte) error
	// SendAsync sends a message to Kafka asynchronously and returns an error if it fails.
	SendAsync(topic string, key []byte, value []byte) error
	// Close closes the producer.
	Close() error
}