-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/19512/
-----------------------------------------------------------

Review request for samza.


Bugs: SAMZA-193
    https://issues.apache.org/jira/browse/SAMZA-193


Repository: samza


Description
-------

Minor fix to the KafkaCheckpointManager to check for a valid producer before 
stopping it


Diffs
-----

  
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala
 a1d2ffe 

Diff: https://reviews.apache.org/r/19512/diff/


Testing
-------


Thanks,

Neha Narkhede

Reply via email to