Batch Processing

[GeorgeShagov]

Hello

Do you plan to implement a batch processing?

RD_EXPORT
ssize_t rd_kafka_consume_batch(rd_kafka_topic_t *rkt, int32_t partition,
int timeout_ms,
rd_kafka_message_t **rkmessages,
size_t rkmessages_size);

thnx in advance

[trinitum]

Hi George, no, I have no plans to implement it. The module is not being actively maintained at the moment, maximum I can do is to accept pull request.