[ 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)