Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-1291

KafkaIO: don't log warning in offset fetcher while closing the reader.

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • P3
    • Resolution: Fixed
    • None
    • 0.5.0
    • io-java-kafka
    • None

    Description

      When the KafkaIO reader is closed, it wakes up two background threads used for reading from Kafka. The wakeup notification results in an exception. One of the threads logs a warning with full stacktrace even though it is part of normal operation. It should not.

      Attachments

        Issue Links

          Activity

            People

              rangadi Raghu Angadi
              rangadi Raghu Angadi
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: