On Fri, Jan 20, 2017 at 11:45 AM, Amit Sela <amitsel...@gmail.com> wrote:
> The WakeupException is being logged and not thrown (it is OK since the > reader was closed due to end-of-microbatch), To avoid such confusion, it is better for KafkaIO not to log it at all, especially if it is already closing (usual case). I will send a PR.
