for those who are still searching. There is task.assignor.class property in later versions. https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java#L766