Uploaded image for project: 'MariaDB MaxScale'
  1. MariaDB MaxScale
  2. MXS-1114

cdc_kafka_producer.py: Track last record delivered to consumer

    XMLWordPrintable

Details

    • Task
    • Status: Closed (View Workflow)
    • Major
    • Resolution: Won't Do
    • 2.0.3
    • N/A
    • avrorouter
    • None

    Description

      When a Kafka consumer is restarted, a common problem that occurs is that the Kafka producer re-sends records that the consumer had already received before the restart. One way to prevent this problem is to design the Kafka producer to keep track of the last record delivered to the consumer, so that if the consumer is restarted, the producer does not send that record again.

      Some users would like cdc_kafka_producer.py to have a mechanism like this.

      Attachments

        Activity

          People

            Unassigned Unassigned
            GeoffMontee Geoff Montee (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Git Integration

                Error rendering 'com.xiplink.jira.git.jira_git_plugin:git-issue-webpanel'. Please contact your Jira administrators.