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

[NU-1823] Fix for schemaless topics in kafka source/sink #7232

Merged
merged 4 commits into from
Nov 29, 2024
Merged

[NU-1823] Fix for schemaless topics in kafka source/sink #7232

merged 4 commits into from
Nov 29, 2024

Commits on Nov 29, 2024

  1. IsTopicWithSchema now fetch topics only if flag for schemaless topics… 

    … is set to true - should resolve problem with azure tests

Added documentation
    @ForrestFairy
    Szymon Bogusz authored and ForrestFairy committed Nov 29, 2024
    Configuration menu
    Copy the full SHA
    b1db0bc View commit details
    Browse the repository at this point in the history

  2. TopicSelectionStrategy when set to fetch all topics, it should not bl… 

    …ock the whole application - will have shorter timeout and if Timeout occurs return empty list from kafka (will still make a call to schema registry)
    @ForrestFairy
    Szymon Bogusz authored and ForrestFairy committed Nov 29, 2024
    Configuration menu
    Copy the full SHA
    e3ca62f View commit details
    Browse the repository at this point in the history

  3. Change in record formatter to add namespace to topic in ad-hoc tests … 

    …(didn't work previously when naming strategy was set)
    @ForrestFairy
    Szymon Bogusz authored and ForrestFairy committed Nov 29, 2024
    Configuration menu
    Copy the full SHA
    cc1523a View commit details
    Browse the repository at this point in the history

  4. Kafka exception also caught and pass with empty list of topics from k… 

    …afka
    @ForrestFairy
    Szymon Bogusz authored and ForrestFairy committed Nov 29, 2024
    Configuration menu
    Copy the full SHA
    d7cce4a View commit details
    Browse the repository at this point in the history