You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/03/11 00:48:53 UTC

kafka git commit: MINOR: incorrect javadoc formatting

Repository: kafka
Updated Branches:
  refs/heads/trunk 0011a3dc3 -> 046519d07


MINOR: incorrect javadoc formatting

When wrapped in a `{code ...}` block, `&lt;&gt;` are not formatted as `<>`.

For instance, see the formatting of the example in https://kafka.apache.org/0102/javadoc/org/apache/kafka/streams/KafkaStreams.html

Author: Aaron Coburn <ac...@amherst.edu>

Reviewers: Matthias J. Sax, Guozhang Wang

Closes #2671 from acoburn/javadoc_formatting


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/046519d0
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/046519d0
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/046519d0

Branch: refs/heads/trunk
Commit: 046519d0714591785cd984ab2d57e193b54a2f19
Parents: 0011a3d
Author: Aaron Coburn <ac...@amherst.edu>
Authored: Fri Mar 10 16:48:48 2017 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Mar 10 16:48:48 2017 -0800

----------------------------------------------------------------------
 streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/046519d0/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
index 2810ff8..8d8626d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
@@ -96,7 +96,7 @@ import static org.apache.kafka.common.utils.Utils.getPort;
  * <p>
  * A simple example might look like this:
  * <pre>{@code
- * Map&lt;String, Object&gt; props = new HashMap&lt;&gt;();
+ * Map<String, Object> props = new HashMap<>();
  * props.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-stream-processing-application");
  * props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
  * props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
@@ -104,7 +104,7 @@ import static org.apache.kafka.common.utils.Utils.getPort;
  * StreamsConfig config = new StreamsConfig(props);
  *
  * KStreamBuilder builder = new KStreamBuilder();
- * builder.stream("my-input-topic").mapValues(value -&gt; value.length().toString()).to("my-output-topic");
+ * builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
  *
  * KafkaStreams streams = new KafkaStreams(builder, config);
  * streams.start();