You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2019/05/23 16:16:00 UTC

[jira] [Created] (SAMZA-2214) KafkaSystemConsumer: Log seek position directly from the underlying consumer

Daniel Nishimura created SAMZA-2214:
---------------------------------------

             Summary: 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


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)