MINOR: Update JavaDoc to use new API
Author: Bill Bejeck
Reviewers: Guozhang Wang Matthias J. Sax<matthias@confluent.io>
Closes from bbejeck/MINOR_fix_java_doc_example_for_1_0_API
@@ -113,10 +113,10 @@ import static org.apache.kafka.streams.StreamsConfig.PROCESSING_GUARANTEE_CONFIG
* props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
* StreamsConfig config = new StreamsConfig(props);
*
- * KStreamBuilder builder = new KStreamBuilder();
- * builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
+ * StreamsBuilder builder = new StreamsBuilder();
+ * builder.<String, String>stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
*
- * KafkaStreams streams = new KafkaStreams(builder, config);
+ * KafkaStreams streams = new KafkaStreams(builder.build(), config);
* streams.start();
* }</pre>
*
