public synchronized <K, V> KStream<K, V> stream(final String topic,
                                                    final Consumed<K, V> consumed) {
        return stream(Collections.singleton(topic), consumed);
    }
Create a {@link KStream} from the specified topic.
The {@code "auto.offset.reset"} strategy, {@link TimestampExtractor}, key and value deserializers
are defined by the options in {@link Consumed} are used.
<p>
Note that the specified input topic must be partitioned by key.
If this is not the case it is the user's responsibility to repartition the data before any key based operation
(like aggregation or join) is applied to the returned {@link KStream}.

@param topic the topic names; cannot be {@code null}
@param consumed      the instance of {@link Consumed} used to define optional parameters
@return a {@link KStream} for the specified topic
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java