Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-2339

Update KafkaSystemAdmin to adhere to the checkpoint replication factor

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • None
    • None
    • None

    Description

      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.

      Attachments

        Activity
          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            bharathkk Bharath Kumarasubramanian
            vartulagrawal Vartul Agrawal
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 1.5h
                1.5h

                Slack

                  Issue deployment