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 <joey.bar...@gmail.com> Authored: Tue Aug 29 16:38:24 2017 +0300 Committer: Aviem Zur <aviem...@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)
