Commit 1d20663

committed

Kafka: various fixes

*) package renaming *) move it out of contrib to I/O module *) get it running as part of the normal travis build, and remove specialization *) remove examples, to be added in a separate PR. Either there should be an addition to an existing example to handle "multiple" streaming sources, or we should have this as an integration test. No need, however, for an example just to show how to use an I/O in a pipeline -- that's what Javadoc is for.

1 parent f5c809d commit 1d20663Copy full SHA for 1d20663

10 files changed

contrib
- examples/kafka
  - pom.xml
  - src/main/java/com/google/cloud/dataflow/contrib/kafka/examples
    - TopHashtagsExample.java
- kafka
  - pom.xml
sdks/java/io
- kafka
  - pom.xml
  - src
    - main/java/org/apache/beam/sdk/io/kafka
    - test/java/org/apache/beam/sdk/io/kafka
      - KafkaIOTest.java
- pom.xml

`‎contrib/examples/kafka/pom.xml‎`

This file was deleted.

Comments

(0)