Method Write

conn.go:1100–1102

Write writes a message to the kafka broker that this connection was established to. The method returns the number of bytes written, or an error if something went wrong. The operation either succeeds or fail, it never partially writes the message. This method is exposed to satisfy the net.Conn inte

(b []byte)

// This method is exposed to satisfy the net.Conn interface but is less efficient
// than the more general purpose WriteMessages method.
func (c *Conn) Write(b []byte) (int, error) {
	return c.WriteCompressedMessages(nil, Message{Value: b})
}

// WriteMessages writes a batch of messages to the connection's topic and
// partition, returning the number of bytes written. The write is an atomic