Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Jiangjie Qin
at 3:01 PM, Jiangjie Qin >wrote: > >> Add the DISCUSS prefix to the email title : ) >> >> From: Jiangjie Qin mailto:j...@linkedin.com>> >> Date: Tuesday, May 12, 2015 at 4:51 PM >> To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" < &g

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Jun Rao
5 at 4:51 PM > To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" < > dev@kafka.apache.org<mailto:dev@kafka.apache.org>> > Subject: Add missing API to old high level consumer > > Hi, > > I just noticed that in KAFKA-1650 (which is before we use KIP) we add

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Gwen Shapira
upgrading > > to > > > > >0.8.2.1 then we should do a 0.8.2.2 release with this fix in it. For > > > > >0.9.0. > > > > >we are pushing for folks to start using the new consumer and that is > > the > > > > >upgrade path we should continue on, i

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Joe Stein
; > > >~ Joe Stein > > > >- - - - - - - - - - - - - - - - - > > > > > > > > http://www.stealth.ly > > > >- - - - - - - - - - - - - - - - - > > > > > > > >On Wed, May 13, 2015 at 6:01 PM, Jiangjie Qin >

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-14 Thread Gwen Shapira
://www.stealth.ly > > >- - - - - - - - - - - - - - - - - > > > > > >On Wed, May 13, 2015 at 6:01 PM, Jiangjie Qin > > > >wrote: > > > > > >> Add the DISCUSS prefix to the email title : ) > > >> > > >> From: Jiangjie Qin mai

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-14 Thread Joe Stein
t; Add the DISCUSS prefix to the email title : ) > >> > >> From: Jiangjie Qin mailto:j...@linkedin.com>> > >> Date: Tuesday, May 12, 2015 at 4:51 PM > >> To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" < > >> dev@kafka.a

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-14 Thread Jiangjie Qin
ote: > >> Add the DISCUSS prefix to the email title : ) >> >> From: Jiangjie Qin mailto:j...@linkedin.com>> >> Date: Tuesday, May 12, 2015 at 4:51 PM >> To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" < >> dev@kafka.apache.org<m

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-13 Thread Joe Stein
01 PM, Jiangjie Qin wrote: > Add the DISCUSS prefix to the email title : ) > > From: Jiangjie Qin mailto:j...@linkedin.com>> > Date: Tuesday, May 12, 2015 at 4:51 PM > To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" < > dev@kafka.apache.org<mailto:d

[DISCUSS] Add missing API to old high level consumer

2015-05-13 Thread Jiangjie Qin
Add the DISCUSS prefix to the email title : ) From: Jiangjie Qin mailto:j...@linkedin.com>> Date: Tuesday, May 12, 2015 at 4:51 PM To: "dev@kafka.apache.org<mailto:dev@kafka.apache.org>" mailto:dev@kafka.apache.org>> Subject: Add missing API to old high level consum

Add missing API to old high level consumer

2015-05-12 Thread Jiangjie Qin
Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map. public void commitOffsets(Map offsetsToCommit, boolean retryOnFailure); This method was added to all the Scala clas