Thanks Guozhang, what is userData for in the Subscription? On Wed, Nov 18, 2015 at 12:05 PM, Guozhang Wang <wangg...@gmail.com> wrote:
> Currently the whole KafkaConsumer interface is tagged as " > @InterfaceStability.Unstable", meaning that the API may change in the > future. We have been very careful to make any dramatic public API changes > but still cannot guarantee this will not happen. > > Member-Id is assigned by the server-side coordinator upon accepting the > consumer to join the specified group, hence it cannot be manually set. But > the memberId will not change as long as the consumer is still part of the > members of the group, so you want to do some sticky assignment you can just > remember the memberId -> partitions map on the consumer side in some > persistent storage so that even when the leader who does the assignment has > failed over other new leaders can still access the past assignment history. > > Guozhang > > > > On Wed, Nov 18, 2015 at 9:02 AM, hsy...@gmail.com <hsy...@gmail.com> > wrote: > > > Hey guys, > > > > I saw the PartitionAssignor is not in public doc API and the package name > > is internals. > > > > Does it mean this API is not stable and could be changed even in minor > > release? > > > > And in the assign method signature, the key for the "subscription" map is > > memberId, what is memberId, can I manually set the id to identify member? > > I want to do some sticky assignment. > > > > > > Thanks! > > > > Best, > > Siyuan > > > > > > -- > -- Guozhang >
