-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/53453/
-----------------------------------------------------------
(Updated Nov. 10, 2016, 6:54 p.m.)
Review request for samza.
Bugs: SAMZA-1042
https://issues.apache.org/jira/browse/SAMZA-1042
Repository: samza
Description
-------
Add optional interface for SystemConsumer checkpontListener() for checkpoint
notifications.
Diffs
-----
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointListener.java
PRE-CREATION
samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java
8dfcc7499659442aabd3085a8787475fe38f29db
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala
c41eadb70f4675816245f7ac40f0db2fc16335f0
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
e0468ee89c89fd720834461771ebb36475475bcb
samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala
cb78223f1b59a78bbeb1e42b5974670a53def504
Diff: https://reviews.apache.org/r/53453/diff/
Testing (updated)
-------
gradlew test.
manual testing with LiKafkaConsumer.
Thanks,
Boris Shkolnik
