[
https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13328:
----------------------------------
Description:
Users may specify a header converter class for their connector directly in the
configuration for that connector. If this occurs, no preflight validation is
performed to ensure that the specified converter is valid.
{{HeaderConverter}} implementations are required to provide a valid
{{ConfigDef}} to the Connect framework via
[HeaderConverter::config|https://github.com/apache/kafka/blob/4eb386f6e060e12e1940c0d780987e3a7c438d74/connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java#L48-L52],
but this object isn't actually leveraged anywhere by Connect.
Connect should make use of this config object during preflight validation for
connectors to fail faster when their header converters are misconfigured.
was:
{{HeaderConverter}} implementations are required to provide a valid
{{ConfigDef}} to the Connect framework via
[HeaderConverter::config|https://github.com/apache/kafka/blob/4eb386f6e060e12e1940c0d780987e3a7c438d74/connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java#L48-L52],
but this object isn't actually leveraged anywhere by Connect.
Connect should make use of this config object during preflight validation for
connectors to fail faster when their header converters are misconfigured.
> Connect does not perform preflight validation for per-connector header
> converters
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-13328
> URL: https://issues.apache.org/jira/browse/KAFKA-13328
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Reporter: Chris Egerton
> Assignee: Chris Egerton
> Priority: Major
>
> Users may specify a header converter class for their connector directly in
> the configuration for that connector. If this occurs, no preflight validation
> is performed to ensure that the specified converter is valid.
> {{HeaderConverter}} implementations are required to provide a valid
> {{ConfigDef}} to the Connect framework via
> [HeaderConverter::config|https://github.com/apache/kafka/blob/4eb386f6e060e12e1940c0d780987e3a7c438d74/connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java#L48-L52],
> but this object isn't actually leveraged anywhere by Connect.
> Connect should make use of this config object during preflight validation for
> connectors to fail faster when their header converters are misconfigured.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
