Kafka client - 0.9

2015-04-23 Thread Bharath Srinivasan
Hi, I'm looking for the 0.9 client release plan. https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design Is there a planned date for this release? Thanks, Bharath

Re: Kafka client - 0.9

2015-04-23 Thread Bharath Srinivasan
d support. > > Are there any specific features you are waiting for? > > Gwen > > On Thu, Apr 23, 2015 at 2:25 PM, Bharath Srinivasan > wrote: > > Hi, > > > > I'm looking for the 0.9 client release plan. > > > > > https://cwiki.apache.org/con

Re: Kafka client - 0.9

2015-04-29 Thread Bharath Srinivasan
Any pointers on this feature? Thanks. On Thu, Apr 23, 2015 at 9:57 PM, Bharath Srinivasan wrote: > Thanks Gwen. > > I'm specifically looking for the consumer rewrite API ( > org.apache.kafka.clients.consumer.KafkaConsumer). Based on the wiki, this > feature is available

Kafka 0.8.2.1 - Listing partitions owned by consumers

2015-05-12 Thread Bharath Srinivasan
Hi, For monitorting purposes, is there a way to find the partitions for a topic that are assigned to consumers in a group? We are using high level consumer and the offsets are stored in kafka. Tried searching for methods in ZKUtils, but could not find anything that gives this information. Any poi

Re: Kafka 0.8.2.1 - Listing partitions owned by consumers

2015-05-12 Thread Bharath Srinivasan
gt; wrote: > > > Perhaps you could try the ConsumerOffsetChecker. The "Owner" field might > > be what you want.. > > > > Aditya > > > > > > From: Bharath Srinivasan [bharath...@gmail.com] > > Sent: Tuesday, Ma

Kafka 0.8.2.2 - CLOSE_WAITS on broker

2016-08-25 Thread Bharath Srinivasan
Hello: We are running a data pipeline application stack using Kafka 0.8.2.2 in production. We have been seeing intermittent CLOSE_WAIT on our kafka brokers frequently and they fill up the file handles pretty quickly. By the time the open file count reaches around 40K, the node becomes unresponsive

Re: Kafka 0.8.2.2 - CLOSE_WAITS on broker

2016-08-26 Thread Bharath Srinivasan
; to some place (like gist) to show us what descriptors are open etc... > > -Jaikiran > > > On Friday 26 August 2016 02:49 AM, Bharath Srinivasan wrote: > >> Hello: >> >> We are running a data pipeline application stack using Kafka 0.8.2.2 in >> product