SAMZA-620; torture test checker should start from oldest offset
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/8aeec8de Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/8aeec8de Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/8aeec8de Branch: refs/heads/samza-sql Commit: 8aeec8defcfb62cd805425811520ca6474973126 Parents: d20ae5c Author: Chris Riccomini <[email protected]> Authored: Fri Mar 27 11:04:09 2015 -0700 Committer: Chris Riccomini <[email protected]> Committed: Fri Mar 27 11:04:09 2015 -0700 ---------------------------------------------------------------------- samza-test/src/main/config/join/checker.samza | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/8aeec8de/samza-test/src/main/config/join/checker.samza ---------------------------------------------------------------------- diff --git a/samza-test/src/main/config/join/checker.samza b/samza-test/src/main/config/join/checker.samza index ab557d9..c0e3df7 100644 --- a/samza-test/src/main/config/join/checker.samza +++ b/samza-test/src/main/config/join/checker.samza @@ -20,6 +20,7 @@ job.name=checker systems.kafka.partitioner.class=org.apache.samza.test.integration.join.EpochPartitioner +systems.kafka.samza.offset.default=oldest # Task task.class=org.apache.samza.test.integration.join.Checker
