You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bo...@apache.org on 2018/09/18 23:01:02 UTC
[05/47] samza git commit: Merge branch 'master' of
https://github.com/apache/samza
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 <bo...@apache.org>
Authored: Tue Oct 24 18:33:03 2017 -0700
Committer: Boris S <bo...@apache.org>
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(-)
----------------------------------------------------------------------