[
https://issues.apache.org/jira/browse/KAFKA-8348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836924#comment-16836924
]
Lifei Chen commented on KAFKA-8348:
-----------------------------------
Hi [~mjsax], I am starting to read and contribute to kafka streams, this is a
small problem I found in the doc when learning the code.
Please review the code when you have time, Thanks a lot :D.
> 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
> Priority: Minor
>
> 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)
