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

[#30870]: support consumer polling timeout in KafkaIO expansion service #30915

Merged
merged 12 commits into from
Apr 16, 2024
Merged

[#30870]: support consumer polling timeout in KafkaIO expansion service #30915

merged 12 commits into from
Apr 16, 2024

Commits on Apr 10, 2024

  1. [apache#30870]: support consumer polling timeout in KafkaIO expansion… 

    … service
    @xianhualiu
    xianhualiu committed Apr 10, 2024
    Configuration menu
    Copy the full SHA
    a647f88 View commit details
    Browse the repository at this point in the history

  2. fixed spotless complains

    @xianhualiu
    xianhualiu committed Apr 10, 2024
    Configuration menu
    Copy the full SHA
    37e267c View commit details
    Browse the repository at this point in the history

  3. fixed python format complains

    @xianhualiu
    xianhualiu committed Apr 10, 2024
    Configuration menu
    Copy the full SHA
    c2c11e5 View commit details
    Browse the repository at this point in the history

  4. Update sdks/python/apache_beam/io/kafka.py 

    Co-authored-by: Jonathan Sabbagh <108473809+jbsabbagh@users.noreply.github.com>
    @xianhualiu @jbsabbagh
    xianhualiu and jbsabbagh authored Apr 10, 2024
    Configuration menu
    Copy the full SHA
    6bf7246 View commit details
    Browse the repository at this point in the history

  5. Update sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/… 

    …KafkaIO.java

Co-authored-by: Jonathan Sabbagh <108473809+jbsabbagh@users.noreply.github.com>
    @xianhualiu @jbsabbagh
    xianhualiu and jbsabbagh authored Apr 10, 2024
    Configuration menu
    Copy the full SHA
    e762571 View commit details
    Browse the repository at this point in the history

  6. Update sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/… 

    …KafkaIO.java

Co-authored-by: Jonathan Sabbagh <108473809+jbsabbagh@users.noreply.github.com>
    @xianhualiu @jbsabbagh
    xianhualiu and jbsabbagh authored Apr 10, 2024
    Configuration menu
    Copy the full SHA
    b2a6196 View commit details
    Browse the repository at this point in the history

Commits on Apr 15, 2024

  1. fixed formating issue

    @xianhualiu
    xianhualiu committed Apr 15, 2024
    Configuration menu
    Copy the full SHA
    90a2012 View commit details
    Browse the repository at this point in the history

  2. fixed pylint and pydoc issues

    @xianhualiu
    xianhualiu committed Apr 15, 2024
    Configuration menu
    Copy the full SHA
    573a2fa View commit details
    Browse the repository at this point in the history

  3. shorten the variable name

    @xianhualiu
    xianhualiu committed Apr 15, 2024
    Configuration menu
    Copy the full SHA
    7bf2f87 View commit details
    Browse the repository at this point in the history

  4. fixed format and upgrade test

    @xianhualiu
    xianhualiu committed Apr 15, 2024
    Configuration menu
    Copy the full SHA
    ed06501 View commit details
    Browse the repository at this point in the history

  5. fixed test

    @xianhualiu
    xianhualiu committed Apr 15, 2024
    Configuration menu
    Copy the full SHA
    2eef472 View commit details
    Browse the repository at this point in the history

Commits on Apr 16, 2024

  1. fixed test

    @xianhualiu
    xianhualiu committed Apr 16, 2024
    Configuration menu
    Copy the full SHA
    feb8186 View commit details
    Browse the repository at this point in the history