Repository: beam Updated Branches: refs/heads/master 56398fcba -> bf16b4a80
Fix KafkaIO javadoc typo Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a77cc22b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a77cc22b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a77cc22b Branch: refs/heads/master Commit: a77cc22b670be9fb554430908748a6d78c55c128 Parents: 56398fc Author: Devon Meunier <[email protected]> Authored: Wed Apr 12 08:47:29 2017 -0400 Committer: Ahmet Altay <[email protected]> Committed: Thu Apr 20 09:48:31 2017 -0700 ---------------------------------------------------------------------- .../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a77cc22b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index 7feb8d0..47657bb 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -199,7 +199,7 @@ import org.slf4j.LoggerFactory; * }</pre> * * <h3>Advanced Kafka Configuration</h3> - * KafakIO allows setting most of the properties in {@link ConsumerConfig} for source or in + * KafkaIO allows setting most of the properties in {@link ConsumerConfig} for source or in * {@link ProducerConfig} for sink. E.g. if you would like to enable offset * <em>auto commit</em> (for external monitoring or other purposes), you can set * <tt>"group.id"</tt>, <tt>"enable.auto.commit"</tt>, etc.
