You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/04/20 16:48:44 UTC
[1/2] beam git commit: Fix KafkaIO javadoc typo
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 <de...@shopify.com>
Authored: Wed Apr 12 08:47:29 2017 -0400
Committer: Ahmet Altay <al...@google.com>
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.
[2/2] beam git commit: This closes #2508
Posted by al...@apache.org.
This closes #2508
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf16b4a8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf16b4a8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bf16b4a8
Branch: refs/heads/master
Commit: bf16b4a80562cb9db1cd4adba354dd393ed7afd0
Parents: 56398fc a77cc22
Author: Ahmet Altay <al...@google.com>
Authored: Thu Apr 20 09:48:33 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Thu Apr 20 09:48:33 2017 -0700
----------------------------------------------------------------------
.../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------