Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/010fa168 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/010fa168 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/010fa168 Branch: refs/heads/NewKafkaSystemConsumer Commit: 010fa168ee2a290b93f5a3b0908709b2c19044ec Parents: bbffb79 e6049b7 Author: Boris S <[email protected]> Authored: Tue Oct 24 18:33:03 2017 -0700 Committer: Boris S <[email protected]> Committed: Tue Oct 24 18:33:03 2017 -0700 ---------------------------------------------------------------------- .../samza/system/kafka/KafkaStreamSpec.java | 9 +++ .../kafka/KafkaCheckpointManagerFactory.scala | 21 ++----- .../org/apache/samza/config/KafkaConfig.scala | 37 +++++++++++- .../samza/system/kafka/KafkaSystemAdmin.scala | 9 ++- .../samza/system/kafka/KafkaSystemFactory.scala | 22 ++++++- .../TestKafkaCheckpointManagerFactory.java | 51 +++++++++++++++++ .../kafka/TestKafkaSystemFactoryJava.java | 60 ++++++++++++++++++++ .../kafka/TestKafkaCheckpointManager.scala | 6 +- .../apache/samza/config/TestKafkaConfig.scala | 13 +++++ 9 files changed, 204 insertions(+), 24 deletions(-) ----------------------------------------------------------------------
