[
https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837314#comment-16837314
]
Vahid Hashemian commented on KAFKA-8348:
----------------------------------------
Sounds good [~mjsax].
> Document of kafkaStreams improvement
> ------------------------------------
>
> Key: KAFKA-8348
> URL: https://issues.apache.org/jira/browse/KAFKA-8348
> Project: Kafka
> Issue Type: Improvement
> Components: documentation, streams
> Affects Versions: 1.0.0, 1.0.1, 1.0.2, 1.1.0, 1.1.1, 2.0.0, 2.0.1, 2.1.0,
> 2.2.0, 2.1.1
> Reporter: Lifei Chen
> Assignee: Lifei Chen
> Priority: Minor
> Fix For: 1.0.3, 1.1.2, 2.0.2, 2.3.0, 2.1.2, 2.2.2
>
>
> 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)
