Thanks Paolo, >From your opinion, would such feature be difficult (possible) to implement? I didn't look into the code yet, I didn't program in C since high school and my skills are quite rusty.
Cheers, Yann On Fri, Sep 15, 2017 at 6:38 PM Paolo Lucente <pa...@pmacct.net> wrote: > > 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 >
_______________________________________________ pmacct-discussion mailing list http://www.pmacct.net/#mailinglists
