AUTO: Yan Wang is out of the office (returning 07/31/2017)

2017-07-22 Thread Yan Wang
I am out of the office until 07/31/2017. Note: This is an automated response to your message "Re: Tuning up mirror maker for high thruput" sent on 7/22/2017 3:27:24 AM. This is the only notification you will receive while this person is away. ** This email and any attachments may contain

max.poll.records and pause

2017-06-23 Thread Yan Wang
How the pause influences max.poll.records? If I have two partitions, say p1 and p2. p1 has number local fetched records > max.poll.records. p2 has no data in local but in the server (not fetched yet). Now, if I pause P1. Does the next poll send fetch request to the server so that I can get data

AUTO: Yan Wang is out of the office (returning 06/01/2017)

2017-05-26 Thread Yan Wang
I am out of the office until 06/01/2017. Note: This is an automated response to your message "Re: [DISCUSS]: KIP-161: streams record processing exception handlers" sent on 5/26/2017 3:20:42 PM. This is the only notification you will receive while this person is away. ** This email and any

AUTO: Yan Wang is out of the office (returning 10/17/2016)

2016-10-13 Thread Yan Wang
I am out of the office until 10/17/2016. Note: This is an automated response to your message "Re: Understanding out of order message processing w/ Streaming" sent on 10/13/2016 2:42:16 AM. This is the only notification you will receive while this person is away. ** This email and any

AUTO: Yan Wang is out of the office (returning 08/08/2016)

2016-07-29 Thread Yan Wang
I am out of the office until 08/08/2016. Note: This is an automated response to your message "Mirrormaker between 0.8.2.1 cluster and 0.10 cluster" sent on 7/29/2016 2:04:44 AM. This is the only notification you will receive while this person is away. ** This email and any attachments may

AUTO: Yan Wang is out of the office (returning 03/17/2016)

2016-03-14 Thread Yan Wang
I am out of the office until 03/17/2016. Note: This is an automated response to your message "New client commitAsync SendFailedException" sent on 3/14/2016 10:18:14 AM. This is the only notification you will receive while this person is away. ** This email and any attachments may contain

Re: GC is running forever

2015-10-17 Thread Yan Wang
ted many long-running java apps but Kafka more than most. In our case, it actually turned out to be a kernel bug. Here is a reference with more details: > > https://groups.google.com/forum/#!topic/mechanical-sympathy/QbmpZxp6C64 > > Thanks, > Paul > _________

GC is running forever

2015-10-15 Thread Yan Wang
Hello Kafka Experts. We have experienced a long running GC problem for a while. GC will eventually eat up all the cpu cycles on the physical box. Have chatted with Gwen regarding this issue during recent ended Hadoop conference at NYC, per her recommendation we switched to G1, but we still see