Lovro Mažgon
Lovro Mažgon
Russ Cox describes it in [this video](https://www.youtube.com/watch?v=yx7lmuwUNv8&feature=youtu.be&t=929), I think it would be a great addition to the list.
**Describe the bug** If two (or more) goroutines are tailing the same file and one of them stops it impacts the other goroutine(s). **Expected behaviour** Other goroutines should keep on...
### Description This PR updates Conduit to use a new Record structure that matches OpenCDC records. Apart from that it: - Updates versions of all builtin plugins and uses `sdk.Connector`...
Collects work needed to implement pipeline config file support in Conduit. - [x] #489 - [x] #490 - [x] #491 - [x] #492 - [ ] #493 - [ ]...
The idea is to simplify the [`Destination` interface](https://github.com/ConduitIO/conduit-connector-sdk/blob/733149cddc0bcdfd1144012f1bf41651355653d1/destination.go#L38) in the SDK and move complexity related to asynchronous writes to the SDK. We need to write a proper design document around...
Change all existing connectors to use the newest version of the SDK and use the new record. Built-in: - [x] [File](https://github.com/ConduitIO/conduit-connector-file) https://github.com/ConduitIO/conduit-connector-file/pull/14 - [x] [Kafka](https://github.com/ConduitIO/conduit-connector-kafka) https://github.com/ConduitIO/conduit-connector-kafka/pull/38 - [x] [Postgres](https://github.com/ConduitIO/conduit-connector-postgres) https://github.com/ConduitIO/conduit-connector-postgres/pull/49...
We need to implement logic that takes a pipeline config file and provisions the pipeline defined in it. If a pipeline with that name already exists it needs to be...
### Description This PR optimizes the semaphore. The semaphore is on the hot path since every message needs to acquire it, an optimization will directly affect the performance of the...
### Feature description The destination connector is responsible for deciding how a record gets encoded and sent to the 3rd party system. This means a user generally can't control what...
Change Conduit to use the OpenCDC record instead of its own record. Depends on #510 and in part on #512 (builtin connectors need to be updated first).