If partition is RD_KAFKA_PARTITION_UA the configured partitioner will
be run for each message (slower), otherwise the messages will be enqueued
to the specified partition directly (faster).
The messages are provided in the array \p rkmessages of count \p message_cnt
elements.
The \p partition and \p msgflags are used for all provided messages.
Honoured \p rkmessages[] fields are:
- payload,len Message payload and length
- key,key_len Optional message key
- _private Message opaque pointer (msg_opaque)
- err Will be set according to success or failure.
Application only needs to check for errors if
return value != \p message_cnt.
@returns the number of messages succesfully enqueued for producing.
@brief Produce multiple messages.
If partition is RD_KAFKA_PARTITION_UA the configured partitioner will be run for each message (slower), otherwise the messages will be enqueued to the specified partition directly (faster).
The messages are provided in the array \p rkmessages of count \p message_cnt elements. The \p partition and \p msgflags are used for all provided messages.
Honoured \p rkmessages[] fields are: - payload,len Message payload and length - key,key_len Optional message key - _private Message opaque pointer (msg_opaque) - err Will be set according to success or failure. Application only needs to check for errors if return value != \p message_cnt.
@returns the number of messages succesfully enqueued for producing.