You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by GitBox <gi...@apache.org> on 2019/10/03 13:35:14 UTC

[GitHub] [samza] VartulAgrawal opened a new pull request #1177: Update KafkaSystemAdmin to adhere to the checkpoint replication factor

VartulAgrawal opened a new pull request #1177: Update KafkaSystemAdmin to adhere to the checkpoint replication factor
URL: https://github.com/apache/samza/pull/1177
 
 
   As part of this PR: https://github.com/apache/samza/pull/789/files#diff-52d8a92e9c8e3d26c4e595919566326aR519 the replicationFactor value defined in the config was dropped since with the kafka client update it cannot be passed to the configs. 
   
   To preserve this config it should be passed to the checkpoint topic spec; this PR adds the change to preserve the value set by the config `task.checkpoint.replication.factor` in the checkpoint kafka topic spec.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services