Hi Yann, I confirm you can't do that with AMQP as the only knob pmacct gives you is the size-based amqp_multi_values. Although not part of your question, with Kafka and you may choose not to leverage the pmacct knob, kafka_multi_values, and use instead batch.num.messages (ie. amount of messages you want to batch before sending to the broker) or queue.buffering.max.ms (queue for some given amount of time, if for example latency is the constraint) offered by librdkafka.
Paolo On Thu, Sep 14, 2017 at 04:12:45PM +0200, Yann Belin wrote: > Hello, > > Does anyone know if there is a way to control the maximum number of > rows sent in an AMQP message? > > amqp_multi_values allows me to do that in an approximate way > (row_size/message_size) but I need to have a finer control on that, > which is not dependent of variations of row size. > > Thanks in advance, > > Yann > > _______________________________________________ > pmacct-discussion mailing list > http://www.pmacct.net/#mailinglists _______________________________________________ pmacct-discussion mailing list http://www.pmacct.net/#mailinglists