DataService should not return records which has id or timestamp less than offsets

agoda-com / kafka-jdbc-connector

Simple way to copy data from relational databases into kafka.

https://github.com/agoda-com/kafka-jdbc-connector/wiki

Apache License 2.0

20 stars 8 forks source link

DataService should not return records which has id or timestamp less than offsets #19

Closed arpanchaudhury closed 7 years ago

arpanchaudhury commented 7 years ago

DataService extractRecord method currently returns records even if it has id or timestamp which is less than or equal to corresponding offset values. Ideally It should return only the records which has id or timestamp greater than their corresponding offsets.

arpanchaudhury commented 7 years ago

Solved!