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)