Q about PartitionAssignor

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

Re: Q about PartitionAssignor

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

Re: Q about PartitionAssignor

It is used to carry data metadata that leader wants to propagate to other members while doing the rebalance. For example, in Kafka Stream userData contains the mapping of stream tasks to partition groups; in Kafka Connector different connectors can also use this field to fill in app-specific

Re: Q about PartitionAssignor

Thanks Guozhang, what is userData for in the Subscription? On Wed, Nov 18, 2015 at 12:05 PM, Guozhang Wang wrote: > Currently the whole KafkaConsumer interface is tagged as " > @InterfaceStability.Unstable", meaning that the API may change in the > future. We have been very