[DRAFT] kafka: adding best effort and consistent mode.
This change adds transactional support to the Kafka connector for changefeeds.
This change uses the conveyor package to deliver mutation to the target database in any of the supported modes of operations.
The conveyor tracks resolved timestamps across all the partitions with a topic, and ensures that the checkpoint used by cdc-sink is advanced based on the minimal resolved timestamp received on all the partitions.
A second commit, refactors the configuration for better readability.
Codecov Report
Attention: Patch coverage is 76.34409% with 22 lines in your changes are missing coverage. Please review.
Project coverage is 75.78%. Comparing base (
4dcfcdd) to head (c6c4efb).
:exclamation: Your organization needs to install the Codecov GitHub app to enable full functionality.
Additional details and impacted files
@@ Coverage Diff @@
## master #843 +/- ##
==========================================
- Coverage 75.91% 75.78% -0.13%
==========================================
Files 226 226
Lines 10938 10962 +24
==========================================
+ Hits 8304 8308 +4
- Misses 1902 1917 +15
- Partials 732 737 +5
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.