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 store_offsets call when last_valid_record is None #693

Merged
merged 2 commits into from
Nov 5, 2024
Merged

fix store_offsets call when last_valid_record is None #693

merged 2 commits into from
Nov 5, 2024

Commits on Oct 31, 2024

  1. fix store_offsets call when last_valid_record is None 

    - Prevent store_offsets from being called before the first message is pulled.
- Add unit test to ensure store_offsets is not called incorrectly.
    @dtrai2
    dtrai2 committed Oct 31, 2024
    Configuration menu
    Copy the full SHA
    a4f1827 View commit details
    Browse the repository at this point in the history

Commits on Nov 4, 2024

  1. fix typo in variable name in test_confluent_kafka_input.py 

    - corrected variable name from `_last_valid_records` to `_last_valid_record`
    @dtrai2
    dtrai2 committed Nov 4, 2024
    Configuration menu
    Copy the full SHA
    0570dc4 View commit details
    Browse the repository at this point in the history