[Bug] Kafka Connect adapter overrides converter schema registry configuration #23268
Open
3 tasks done
Labels
type/bug
The PR fixed a bug or issue reported a bug
Search before asking
Read release policy
Version
Linux, Java 17, main
Minimal reproduce step
Configure a Kafka Connect based IO connector like Debezium and try use it with a Kafka schema registry.
It will appear to work at first because it will write to the mock registry but on restart of the source will fail to read from offsets topic because lookup from schema registry will fail (as mock registry will now be empty).
What did you expect to see?
That Kafka Connect adapter would transparently pass through properties for schema registry so that url, auth etc can be configured correctly.
What did you see instead?
value.converter.schema.registry.url
is forcibly overrriden to"mock"
making it impossible to use schema registry with Kafka Connect adapter based sourcesAnything else?
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: