[ 
https://issues.apache.org/jira/browse/SAMZA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Daniel Nishimura resolved SAMZA-2214.
-------------------------------------
    Resolution: Not A Problem

> KafkaSystemConsumer: Log seek position directly from the underlying consumer
> ----------------------------------------------------------------------------
>
>                 Key: SAMZA-2214
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2214
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Daniel Nishimura
>            Assignee: Daniel Nishimura
>            Priority: Major
>
> I came across what might be an intermittent bug on the Kafka consumer, but I 
> was not able to reproduce it. From the logs, it appeared the 
> KafkaSystemConsumer set the correct starting offset, but upon the first poll, 
> the event with the latest offset was received. This change should log the 
> actual position of the topic partition on the consumer after calling seek on 
> the consumer to help with future debugging.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to