Method ReadMessage

conn.go:730–734

ReadMessage reads the message at the current offset from the connection, advancing the offset on success so the next call to a read method will produce the next message. Because this method allocate memory buffers for the message key and value it is less memory-efficient than Read, but has the adva

(maxBytes int)

// This method is provided for convenience purposes but is much less efficient
// than using the more general purpose ReadBatch method.
func (c *Conn) ReadMessage(maxBytes int) (Message, error) {
	batch := c.ReadBatch(1, maxBytes)
	msg, err := batch.ReadMessage()
	return msg, coalesceErrors(silentEOF(err), batch.Close())
}

// ReadBatch reads a batch of messages from the kafka server. The method always
// returns a non-nil Batch value. If an error occurred, either sending the fetch