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

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 0.5.0
• Component/s: io-java-kafka
• Assignee: Raghu Angadi
• Reporter: Raghu Angadi
• Created: 20/Jan/17 21:51
• Updated: 16/May/20 13:21
• Resolved: 21/Jan/17 15:17

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.

Issue Links

• links to: GitHub Pull Request #1804