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

kafka: add upstream-kafka-consumer #24431

Merged
merged 7 commits into from
Dec 11, 2022
Merged

kafka: add upstream-kafka-consumer #24431

merged 7 commits into from
Dec 11, 2022

Commits on Dec 9, 2022

  1. kafka: upstream-pointing kafka consumer 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 9, 2022
    Configuration menu
    Copy the full SHA
    cca6e61 View commit details
    Browse the repository at this point in the history

  2. kafka: common mock base in kafka mocks 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 9, 2022
    Configuration menu
    Copy the full SHA
    88146ab View commit details
    Browse the repository at this point in the history

  3. kafka: prettify inbound record + cleanup consumer 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 9, 2022
    Configuration menu
    Copy the full SHA
    8290fcd View commit details
    Browse the repository at this point in the history

  4. kafka: remove consumer-buffer draining for initial PR 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 9, 2022
    Configuration menu
    Copy the full SHA
    50b03f3 View commit details
    Browse the repository at this point in the history

  5. kafka: some renames, partition assignment, missing test 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 9, 2022
    Configuration menu
    Copy the full SHA
    26fb9ba View commit details
    Browse the repository at this point in the history

Commits on Dec 10, 2022

  1. kafka: even better unit tests + consts 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 10, 2022
    Configuration menu
    Copy the full SHA
    6331d43 View commit details
    Browse the repository at this point in the history

Commits on Dec 11, 2022

  1. kafka: actually store TPs as unique_ptr 

    Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
    @adamkotwasinski
    adamkotwasinski committed Dec 11, 2022
    Configuration menu
    Copy the full SHA
    74fef0d View commit details
    Browse the repository at this point in the history