[ 
https://issues.apache.org/jira/browse/SAMZA-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Bharath Kumarasubramanian reassigned SAMZA-2339:
------------------------------------------------

    Assignee: Bharath Kumarasubramanian

> Update KafkaSystemAdmin to adhere to the checkpoint replication factor
> ----------------------------------------------------------------------
>
>                 Key: SAMZA-2339
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2339
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Vartul Agrawal
>            Assignee: Bharath Kumarasubramanian
>            Priority: Major
>          Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> 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: [https://github.com/apache/samza/pull/1177] adds the change to 
> preserve the value set by the config {{task.checkpoint.replication.factor}} 
> in the checkpoint kafka topic spec.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to