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

[SPARK-28367][SS] Use new KafkaConsumer.poll API in Kafka connector #25135

Closed
wants to merge 6 commits into from
Closed

[SPARK-28367][SS] Use new KafkaConsumer.poll API in Kafka connector #25135

wants to merge 6 commits into from

Commits on Jul 12, 2019

  1. [SPARK-28367][SS] Use new KafkaConsumer.poll API in Kafka connector

    @gaborgsomogyi
    gaborgsomogyi committed Jul 12, 2019
    Configuration menu
    Copy the full SHA
    ad1863a View commit details
    Browse the repository at this point in the history

Commits on Jul 15, 2019

  1. Add sleep + remove duplications

    @gaborgsomogyi
    gaborgsomogyi committed Jul 15, 2019
    Configuration menu
    Copy the full SHA
    f92c758 View commit details
    Browse the repository at this point in the history

Commits on Jul 16, 2019

  1. Minimize wait time

    @gaborgsomogyi
    gaborgsomogyi committed Jul 16, 2019
    Configuration menu
    Copy the full SHA
    2968c2a View commit details
    Browse the repository at this point in the history

  2. Change wait approach + added proper error message

    @gaborgsomogyi
    gaborgsomogyi committed Jul 16, 2019
    Configuration menu
    Copy the full SHA
    2ed24d3 View commit details
    Browse the repository at this point in the history

Commits on Aug 6, 2019

  1. Increase kafkaConsumer.pollTimeoutMs

    @gaborgsomogyi
    gaborgsomogyi committed Aug 6, 2019
    Configuration menu
    Copy the full SHA
    69c7ca5 View commit details
    Browse the repository at this point in the history

  2. Improve error message when assigned partitions is empty

    @gaborgsomogyi
    gaborgsomogyi committed Aug 6, 2019
    Configuration menu
    Copy the full SHA
    82f1520 View commit details
    Browse the repository at this point in the history