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)
