SAMZA-1075: Refactor SystemAdmin Interface to expose a common method to create streams
authorJacob Maes <jmaes@linkedin.com>
Fri, 17 Feb 2017 20:49:19 +0000 (12:49 -0800)
committerJacob Maes <jmaes@linkedin.com>
Fri, 17 Feb 2017 20:49:19 +0000 (12:49 -0800)
commit7e7747fb99b30aa25078b5a59911c39d32f95921
tree3d0045f15e51becca5f34f18da55a780d94e75ba
parent8515448a2023ae6c78b9b0bb8e297cf346775e13
SAMZA-1075: Refactor SystemAdmin Interface to expose a common method to create streams

Author: Jacob Maes <jmaes@linkedin.com>

Reviewers: Yi Pan (Data Infrastructure) <nickpan47@gmail.com>

Closes #53 from jmakes/samza-1075
samza-api/src/main/java/org/apache/samza/system/StreamSpec.java [new file with mode: 0644]
samza-api/src/main/java/org/apache/samza/system/StreamValidationException.java [new file with mode: 0644]
samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java [new file with mode: 0644]
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemAdminJava.java [new file with mode: 0644]
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala