Kafka schema prefix

[Licenser]

Pull request

Description

Allow schema prefixes to be handled via a pre-processor

Related

• RFC
• Related Issues: fixes #000, closed #000
• Related docs PR

Checklist

• The RFC, if required, has been submitted and approved
• Any user-facing impact of the changes is reflected in docs.tremor.rs
• The code is tested
• Use of unsafe code is reasoned about in a comment
• Update CHANGELOG.md appropriately, recording any changes, bug fixes, or other observable changes in behavior
• The performance impact of the change is measured (see below)

Performance

[codecov]

Codecov Report

Merging #2351 (a6616c0) into main (c15dda0) will increase coverage by 36.62%.
The diff coverage is 91.02%.

Additional details and impacted files

@@             Coverage Diff             @@
##             main    #2351       +/-   ##
===========================================
+ Coverage   54.32%   90.95%   +36.62%     
===========================================
  Files         264      279       +15     
  Lines       39255    59553    +20298     
===========================================
+ Hits        21325    54165    +32840     
+ Misses      17930     5388    -12542     

Flag	Coverage Δ
unittests	90.95% <91.02%> (+36.62%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Files	Coverage Δ
src/config.rs	98.30% <100.00%> (+4.22%)	⬆️
src/connectors/impls/file.rs	91.79% <100.00%> (+2.05%)	⬆️
src/connectors/impls/gpubsub/producer.rs	98.06% <100.00%> (+94.81%)	⬆️
src/connectors/impls/http/client.rs	87.76% <100.00%> (+1.79%)	⬆️
src/connectors/impls/kafka/producer.rs	87.27% <100.00%> (+5.00%)	⬆️
src/connectors/impls/otel/logs.rs	97.90% <ø> (+39.69%)	⬆️
src/connectors/impls/otel/metrics.rs	97.63% <ø> (+81.04%)	⬆️
src/connectors/impls/otel/trace.rs	100.00% <ø> (+13.84%)	⬆️
src/connectors/impls/stdio.rs	95.71% <100.00%> (+0.88%)	⬆️
src/connectors/impls/tcp/client.rs	95.16% <100.00%> (+3.86%)	⬆️
... and 51 more

... and 182 files with indirect coverage changes

---

Continue to review full report in Codecov by Sentry.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update c15dda0...a6616c0. Read the comment docs.

[mfelsche]

Some minor typoes and small nitpicks. Otherwise looks good to go.