Hello,
Do Kafka protocol & KafkaConsumer (java) client address the following need?
The caller specifies that it needs N number of records with a max wait time of
Tn milliseconds. If N records are available within Tn, the records are returned
to the caller. If Tn expires, then the caller gets w
"max.poll.records" config property can be used to limit the number of
records returned
in each consumer poll() method call.
On Fri, Sep 23, 2016 at 10:49 PM, Ramanan, Buvana (Nokia - US) <
buvana.rama...@nokia-bell-labs.com> wrote:
> Hello,
>
> Do Kafka protocol & KafkaConsumer (java) client addr
: specifying exact number of records to fetch
"max.poll.records" config property can be used to limit the number of records
returned in each consumer poll() method call.
On Fri, Sep 23, 2016 at 10:49 PM, Ramanan, Buvana (Nokia - US) <
buvana.rama...@nokia-bell-labs.com> wrote:
>
