Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6456

Improve JavaDoc of SourceTask#poll() to discourage indefinite blocking

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 1.0.0
    • Fix Version/s: 1.1.0
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      The docs of poll() currently say "This method should block if no data is currently available". This causes the task from transitioning to PAUSED state, if there's no data available for a longer period of time. I'd therefore suggest to reword like this:

      This method should block if no data is currently available but return control to Kafka Connect periodically (by returning null).

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                gunnar.morling Gunnar Morling
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: