public Produced<K, V> withStreamPartitioner(final StreamPartitioner<? super K, ? super V> partitioner) {
        this.partitioner = partitioner;
        return this;
    }
Produce records using the provided partitioner.
@param partitioner   the function used to determine how records are distributed among partitions of the topic,
                     if not specified and the key serde provides a {@link WindowedSerializer} for the key
                     {@link WindowedStreamPartitioner} will be used&mdash;otherwise {@link DefaultStreamPartitioner} will be used
@return this
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java