Hi Saeed, Kafka Streams takes care of assigning partitions to consumers automatically for you. You don't have to write anything explicit to do that. See WordCountDemo.java as an example. Was there another reason you wanted control over partition assignment?
Thanks Eno > On 7 Jun 2016, at 20:02, Saeed Ansari <saeed.ans...@gmail.com> wrote: > > Hi, > I have started a small Kafka streaming application. I need to assign > partitions to consumers in a consumer group. I am not sure where to start > and how to structure consumer groups in KafkaStreams. > > I found that there is a StreamPartitionAssignor that can be added to > config, but still I do not know how to configure it and what parameters to > config. > > Any help is really appreciated. > > Thank you, > Saeed
