Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Concurrent idempotent producer error handling fixes #1172

Merged
merged 6 commits into from
Feb 9, 2022
Merged

Concurrent idempotent producer error handling fixes #1172

merged 6 commits into from
Feb 9, 2022

Commits on Aug 14, 2021

  1. Use sharedPromise for some cluster functions. 

    Use mutex lock for idempotent producer critical section
    @t-d-d
    t-d-d committed Aug 14, 2021
    Configuration menu
    Copy the full SHA
    3a4caa5 View commit details
    Browse the repository at this point in the history

Commits on Sep 6, 2021

  1. Correct cluster.connect method

    @t-d-d
    t-d-d committed Sep 6, 2021
    Configuration menu
    Copy the full SHA
    4f127f8 View commit details
    Browse the repository at this point in the history

Commits on Sep 18, 2021

  1. Merge branch 'master' into concurrent_idempotent_produce

    @t-d-d
    t-d-d committed Sep 18, 2021
    Configuration menu
    Copy the full SHA
    8b7fae6 View commit details
    Browse the repository at this point in the history

Commits on Feb 9, 2022

  1. Merge branch 'master' into concurrent_idempotent_produce

    @Nevon
    Nevon committed Feb 9, 2022
    Configuration menu
    Copy the full SHA
    fa632d8 View commit details
    Browse the repository at this point in the history

  2. Ensure cluster methods retain their return type

    @Nevon
    Nevon committed Feb 9, 2022
    Configuration menu
    Copy the full SHA
    1a1126e View commit details
    Browse the repository at this point in the history

  3. Ensure no duplicate messages in concurrent produce calls test

    @Nevon
    Nevon committed Feb 9, 2022
    Configuration menu
    Copy the full SHA
    5cee69a View commit details
    Browse the repository at this point in the history