You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by av...@apache.org on 2017/08/29 15:35:27 UTC

[1/2] beam git commit: Add README.md to KafkaIO

Repository: beam
Updated Branches:
  refs/heads/master e33cc24a5 -> f816ad879


Add README.md to KafkaIO


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

Branch: refs/heads/master
Commit: bf1b0a5e9e95abf0521e081ba575c789f46ba499
Parents: e33cc24
Author: Joey Baruch <jo...@gmail.com>
Authored: Tue Aug 29 16:38:24 2017 +0300
Committer: Aviem Zur <av...@gmail.com>
Committed: Tue Aug 29 18:33:57 2017 +0300

----------------------------------------------------------------------
 sdks/java/io/kafka/README.md | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/bf1b0a5e/sdks/java/io/kafka/README.md
----------------------------------------------------------------------
diff --git a/sdks/java/io/kafka/README.md b/sdks/java/io/kafka/README.md
new file mode 100644
index 0000000..07d00a1
--- /dev/null
+++ b/sdks/java/io/kafka/README.md
@@ -0,0 +1,36 @@
+<!--
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+-->
+
+KafkaIO contains I/O transforms which allow you to read/write messages from/to [Apache Kafka](http://kafka.apache.org/).
+
+## Dependencies
+
+To use KafkaIO you must first add a dependency on `beam-sdks-java-io-kafka`
+
+```maven
+<dependency>
+    <groupId>org.apache.beam</groupId>
+    <artifactId>beam-sdks-java-io-kafka</artifactId>
+    <version>...</version>
+</dependency>
+```
+
+## Documentation
+
+- [KafkaIO.java](https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java)


[2/2] beam git commit: This closes #3780

Posted by av...@apache.org.
This closes #3780


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

Branch: refs/heads/master
Commit: f816ad87923610bd3fe507a298ac53ea49b4174a
Parents: e33cc24 bf1b0a5
Author: Aviem Zur <av...@gmail.com>
Authored: Tue Aug 29 18:34:33 2017 +0300
Committer: Aviem Zur <av...@gmail.com>
Committed: Tue Aug 29 18:34:33 2017 +0300

----------------------------------------------------------------------
 sdks/java/io/kafka/README.md | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
----------------------------------------------------------------------