On Wed, Jun 8, 2016 at 1:56 PM, Jesse Anderson <[email protected]> wrote:
> [pool-2-thread-1] INFO org.apache.beam.sdk.io.kafka.KafkaIO - Reader-0: > resuming eventsim-0 at default offset > [...] > [pool-2-thread-1] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka > commitId : 23c69d62a0cabf06 > [pool-2-thread-1] WARN org.apache.beam.sdk.io.kafka.KafkaIO - Reader-0: > getWatermark() : no records have been read yet. > [pool-77-thread-1] INFO org.apache.beam.sdk.io.kafka.KafkaIO - Reader-0: > Returning > from consumer pool loop > [pool-78-thread-1] WARN org.apache.beam.sdk.io.kafka.KafkaIO - Reader-0: > exception while fetching latest offsets. ignored. > this reader is closed before the exception. The exception is due to an action during close and can be ignored. The main question is why this was closed...
