Re: offsets.retention.minutes

2016-04-03 Thread William Grim
This is a legitimate question. Anyone have an opinion about changing the default behavior? If not, I can just submit a patch that does this. On Sat, Apr 2, 2016 at 10:59 PM, William Grim wrote: > ? > > On Fri, Apr 1, 2016 at 11:29 PM, William Grim wrote: > >> Hi, >>

Re: offsets.retention.minutes

2016-04-02 Thread William Grim
? On Fri, Apr 1, 2016 at 11:29 PM, William Grim wrote: > Hi, > > I read the reasoning about using offsets.retention.minutes at > https://mail-archives.apache.org/mod_mbox/kafka-users/201602.mbox/%3ccaaofhrah8p_a1yebfnh4wzsjwgiqpob_pr6hn4nymtluqqb...@mail.gmail.com%3E, > but ca

offsets.retention.minutes

2016-04-01 Thread William Grim
Hi, I read the reasoning about using offsets.retention.minutes at https://mail-archives.apache.org/mod_mbox/kafka-users/201602.mbox/%3ccaaofhrah8p_a1yebfnh4wzsjwgiqpob_pr6hn4nymtluqqb...@mail.gmail.com%3E, but can we agree that the original reason behind it is wrong? In my personal world view, of

KafkaConsumer.poll(long) pauses indefinitely

2016-02-10 Thread William Grim
Hi, I'm noticing that when we have a thread that comes up and calls KafkaConsumer.poll(long), it will pause for a much longer time than our 1s timeout. It looks like this is probably happening when kafka gets down to calling ConsumerNetworkClient.epollWait after calling ConsumerNetworkClient.poll