Hi Vamsi, Consumer partition assignment is always within a single group. You can find the java docs for the PartitionAssignor interface here:
https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/RangeAssignor.html StreamPartitionAssignor is one implementation of the interface which is used exclusively in Kafka Streams. Guozhang On Tue, Feb 2, 2016 at 1:37 AM, Achanta Vamsi Subhash < achanta.va...@flipkart.com> wrote: > Hi all, > > I am going through the partition assignment logic in the Kafka new > consumer. Is there any documentation for the logic implemented? It would be > great if some one can write the algorithm for consumer partition assignment > (within a group and across groups). > > -- > Regards > Vamsi Subhash > -- -- Guozhang
