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

Fix franz offset out #665

Merged
merged 11 commits into from
Sep 16, 2024
Merged

Fix franz offset out #665

merged 11 commits into from
Sep 16, 2024

Commits on Sep 16, 2024

  1. Reapply "use franz-go in kafka plugin (#646)" (#664) 

    This reverts commit 1378a87.
    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    4a5f9df View commit details
    Browse the repository at this point in the history

  2. set 30s connect timeout to broker

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    e5e6e26 View commit details
    Browse the repository at this point in the history

  3. add TestAssembleOffset

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    8454a11 View commit details
    Browse the repository at this point in the history

  4. set timestamp now in out kafka message

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    05b3412 View commit details
    Browse the repository at this point in the history

  5. goroutine per kafka partition consuming

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    45b0c12 View commit details
    Browse the repository at this point in the history

  6. ready check for kafka consumer

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    a9db200 View commit details
    Browse the repository at this point in the history

  7. rm kafka input option max_concurrent_fetches

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    0f557ba View commit details
    Browse the repository at this point in the history

  8. Revert "rm kafka input option max_concurrent_fetches" 

    This reverts commit 216d4cb.
    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    6ee2772 View commit details
    Browse the repository at this point in the history

  9. gomaxprocs*1 default for kafka consumer max_concurrent_fetches

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    0483667 View commit details
    Browse the repository at this point in the history

  10. Revert "gomaxprocs*1 default for kafka consumer max_concurrent_fetches" 

    This reverts commit b551951.
    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    aadf4b6 View commit details
    Browse the repository at this point in the history

  11. rm ConsumeClaim

    @DmitryRomanov
    DmitryRomanov committed Sep 16, 2024
    Configuration menu
    Copy the full SHA
    5877a35 View commit details
    Browse the repository at this point in the history