Vartul Agrawal created SAMZA-2339:
-------------------------------------
Summary: 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
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)
