Lifei Chen created KAFKA-8348:
---------------------------------
Summary: Document of kafkaStreams improvement
Key: KAFKA-8348
URL: https://issues.apache.org/jira/browse/KAFKA-8348
Project: Kafka
Issue Type: Improvement
Components: documentation, streams
Reporter: Lifei Chen
Assignee: Lifei Chen
there is an out of date and error example in kafkaStreams.java for current
version.
* Map is not supported for initial StreamsConfig properties
* `int` does not support `toString`
related code:
{code:java}
// kafkaStreams.java
* <p>
* A simple example might look like this:
* <pre>{@code
* Properties props = new Properties();
* props.put(StreamsConfig.APPLICATION_ID_CONFIG,
"my-stream-processing-application");
* props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
* props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG,
Serdes.String().getClass());
* props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG,
Serdes.String().getClass());
*
* StreamsBuilder builder = new StreamsBuilder();
* builder.<String, String>stream("my-input-topic").mapValues(value ->
String.valueOf(value.length())).to("my-output-topic");
*
* KafkaStreams streams = new KafkaStreams(builder.build(), props);
* streams.start();
* }</pre>{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
