Destination - route records to topic based on metadata #130
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description
Adds the ability to specify a Go template in the destination parameter
topic
. The default of this parameter was changed to{{ index .Metadata "opencdc.collection" }}
, which means that records will be routed to the topic based on the collection they come from by default. The user can still specify a static topic.Additionally, the code in this PR makes producing of records a bit safer, by ensuring that encountering an error when preparing the record won't disregard already produced records. It also sneaks in some housekeeping that makes sure we validate generated files are up to date and that golangci-lint can be updated using dependabot.
Fixes ConduitIO/conduit#1477
Quick checks: