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

Ensure calls to Producer.produce* do not block #581

Merged
merged 11 commits into from
Jan 11, 2023
Merged

Ensure calls to Producer.produce* do not block #581

merged 11 commits into from
Jan 11, 2023

Commits on Jan 10, 2023

  1. Ensure calls to Producer.produce* do not block 

    Records to be produced are placed in Chunks in a bounded ZIO Queue, which is processed by a stream running on the Blocking thread pool. The result is communicated back via a Promise. This way we can be sure that calls to `Producer.produce*` never block the ZIO thread pool without incurring the overhead of shifting to the blocking thread pool for every record or chunk of records.
    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    a2e5a0e View commit details
    Browse the repository at this point in the history

  2. Remove printlns

    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    91345af View commit details
    Browse the repository at this point in the history

  3. Remove printlns

    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    716de19 View commit details
    Browse the repository at this point in the history

  4. Discarded non-Unit value

    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    ae33f02 View commit details
    Browse the repository at this point in the history

  5. Merge remote-tracking branch 'origin/master' into non-blocking-produc… 

    …er-send
    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    640a86a View commit details
    Browse the repository at this point in the history

  6. Update zio-kafka/src/main/scala/zio/kafka/producer/ProducerSettings.s… 

    …cala

Co-authored-by: Jules Ivanic <[email protected]>
    @svroonland @guizmaii
    svroonland and guizmaii authored Jan 10, 2023
    Configuration menu
    Copy the full SHA
    cabbdbd View commit details
    Browse the repository at this point in the history

  7. Explicitly handle errors in Producer.close

    @svroonland
    svroonland committed Jan 10, 2023
    Configuration menu
    Copy the full SHA
    9aec63c View commit details
    Browse the repository at this point in the history

Commits on Jan 11, 2023

  1. Close blocking

    @svroonland
    svroonland committed Jan 11, 2023
    Configuration menu
    Copy the full SHA
    7507378 View commit details
    Browse the repository at this point in the history

  2. Eliminate serializedRecords from closure

    @svroonland
    svroonland committed Jan 11, 2023
    Configuration menu
    Copy the full SHA
    c2e7c89 View commit details
    Browse the repository at this point in the history

  3. Tweak

    @svroonland
    svroonland committed Jan 11, 2023
    Configuration menu
    Copy the full SHA
    34e39a3 View commit details
    Browse the repository at this point in the history

  4. Merge remote-tracking branch 'origin/master' into non-blocking-produc… 

    …er-send
    @svroonland
    svroonland committed Jan 11, 2023
    Configuration menu
    Copy the full SHA
    610b3e6 View commit details
    Browse the repository at this point in the history