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 <[email protected]> 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, [email protected] <[email protected]> > wrote: > >> In the new API, the explicit commit offset method call only works for >> subscribe consumer, not the assign consumer, correct? >> >> Best, >> Siyuan >> > >
