WriteMessages writes a batch of messages to the connection's topic and partition, returning the number of bytes written. The write is an atomic operation, it either fully succeeds or fails.
(msgs ...Message)
| 1105 | // partition, returning the number of bytes written. The write is an atomic |
| 1106 | // operation, it either fully succeeds or fails. |
| 1107 | func (c *Conn) WriteMessages(msgs ...Message) (int, error) { |
| 1108 | return c.WriteCompressedMessages(nil, msgs...) |
| 1109 | } |
| 1110 | |
| 1111 | // WriteCompressedMessages writes a batch of messages to the connection's topic |
| 1112 | // and partition, returning the number of bytes written. The write is an atomic |