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 "pure virtual method called" in kafka_source #34

Open
wants to merge 6 commits into
base: master
Choose a base branch
from
Open

fix "pure virtual method called" in kafka_source #34

wants to merge 6 commits into from

Commits on Sep 1, 2021

  1. Update kafka_source.h

    @vyskubov
    vyskubov authored Sep 1, 2021
    Configuration menu
    Copy the full SHA
    db7e16e View commit details
    Browse the repository at this point in the history

Commits on Sep 2, 2021

  1. wait for kafka_source::thread_f() to finish 

    wait for kafka_source_base::thread_f() to finish before closing and destroying kafka_source
    @vyskubov
    vyskubov authored Sep 2, 2021
    Configuration menu
    Copy the full SHA
    15a8742 View commit details
    Browse the repository at this point in the history

  2. Update kafka_source.h 

    check exit condition in consuming loop
    @vyskubov
    vyskubov authored Sep 2, 2021
    Configuration menu
    Copy the full SHA
    3923dfa View commit details
    Browse the repository at this point in the history

  3. Update kafka_source.h

    @vyskubov
    vyskubov authored Sep 2, 2021
    Configuration menu
    Copy the full SHA
    5f23c83 View commit details
    Browse the repository at this point in the history

  4. Update kafka_source.h 

    add specializations
    @vyskubov
    vyskubov authored Sep 2, 2021
    Configuration menu
    Copy the full SHA
    7c1c0c8 View commit details
    Browse the repository at this point in the history

  5. remove double call to close()

    @vyskubov
    vyskubov authored Sep 2, 2021
    Configuration menu
    Copy the full SHA
    b97dc5f View commit details
    Browse the repository at this point in the history