You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Bharath Kumarasubramanian (Jira)" <ji...@apache.org> on 2019/10/09 18:52:00 UTC
[jira] [Assigned] (SAMZA-2339) Update KafkaSystemAdmin to adhere to
the checkpoint replication factor
[ 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)