ConduitIO / conduit

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
https://conduit.io
Apache License 2.0
363 stars 42 forks source link

Use connector protocol v2 #1622

Open lovromazgon opened 4 weeks ago

lovromazgon commented 4 weeks ago

Description

This PR includes code changes to use opencdc.Record everywhere. It removes the old record package entirely. It also updates the connector protocol and SDK to the latest version, so we use the same record across the board. The code is updated according to the changes that were already done in the protocol.

Most of the code changes are straightforward, it's just that there are a lot. I posted a few comments below which call out the important bits, I strongly recommend reading them through before reviewing this PR.

The next PR will remove a bunch of code in pkg/foundation and use the packages in conduit-commons instead.

Part of https://github.com/ConduitIO/conduit/issues/1433.

Quick checks: