Details
-
Bug
-
Resolution: Done
-
Critical
-
0.6.2
-
None
Description
The MySQL connector upon startup attempts to read the database history topic to the end, but the current logic will stop early if there are timeouts or other issues. The logic should change to:
- Read the last offsets for the assigned topic partition(s) with consumer.endOffsets(consumer.assignment())
- Consume the messages while the offset of any message is less than that end offset for the corresponding partition.
See Connect's KafkaBasedLog for an example of how this is done.
Attachments
Issue Links
- is duplicated by
-
DBZ-448 KafkaDatabaseHistory recover does not error if it does not reach the end of the db-history topic
- Closed