I suppose I should have added one qualification to that. The commit API will not work for a consumer using manual assignment if its groupId is shared with another consumer using automatic assignment (with subscribe()). When a consumer group is active, Kafka only allows commits from members of that group.
-Jason On Fri, Nov 20, 2015 at 3:41 PM, Jason Gustafson <ja...@confluent.io> wrote: > Hey Siyuan, > > The commit API should work the same regardless whether subscribe() or > assign() was used. Does this not appear to be working? > > Thanks, > Jason > > On Wed, Nov 18, 2015 at 4:40 PM, hsy...@gmail.com <hsy...@gmail.com> > wrote: > >> In the new API, the explicit commit offset method call only works for >> subscribe consumer, not the assign consumer, correct? >> >> Best, >> Siyuan >> > >
