You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Raghu Angadi (JIRA)" <ji...@apache.org> on 2017/01/20 21:52:26 UTC

[jira] [Created] (BEAM-1291) KafkaIO: don't log warning in offset fetcher while closing the reader.

Raghu Angadi created BEAM-1291:
----------------------------------

             Summary: KafkaIO: don't log warning in offset fetcher while closing the reader.
                 Key: BEAM-1291
                 URL: https://issues.apache.org/jira/browse/BEAM-1291
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-extensions
            Reporter: Raghu Angadi
            Assignee: Raghu Angadi
            Priority: Minor


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)