beam-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jesse Anderson <je...@smokinghand.com>
Subject Re: KafkaIO Questions
Date Wed, 08 Jun 2016 21:20:28 GMT
Still open to screensharing and resolving over a hangout.

On Wed, Jun 8, 2016 at 5:19 PM Raghu Angadi <rangadi@google.com> wrote:

> On Wed, Jun 8, 2016 at 1:56 PM, Jesse Anderson <jesse@smokinghand.com>
> 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...
>

Mime
View raw message