[
https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14843:
---------------------------------
Assignee: Jorge Esteban Quilcate Otoya
> Connector plugins config endpoint does not include Common configs
> -----------------------------------------------------------------
>
> Key: KAFKA-14843
> URL: https://issues.apache.org/jira/browse/KAFKA-14843
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 3.2.0
> Reporter: Jorge Esteban Quilcate Otoya
> Assignee: Jorge Esteban Quilcate Otoya
> Priority: Major
>
> Connector plugins GET config endpoint introduced in
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-769%3A+Connect+APIs+to+list+all+connector+plugins+and+retrieve+their+configuration+definitions|https://cwiki.apache.org/confluence/display/KAFKA/KIP-769%3A+Connect+APIs+to+list+all+connector+plugins+and+retrieve+their+configuration+definitions,]
> allows to get plugin configuration from the rest endpoint.
> This configuration only includes the plugin configuration, but not the base
> configuration of the Sink/Source Connector.
> For instance, when validating the configuration of a plugin, _all_ configs
> are returned:
> ```
> curl -s
> $CONNECT_URL/connector-plugins/io.aiven.kafka.connect.http.HttpSinkConnector/config
> | jq -r '.[].name' | sort -u | wc -l
> 21
> curl -s
> $CONNECT_URL/connector-plugins/io.aiven.kafka.connect.http.HttpSinkConnector/config/validate
> -XPUT -H 'Content-type: application/json' --data "\{\"connector.class\":
> \"io.aiven.kafka.connect.http.HttpSinkConnector\", \"topics\":
> \"example-topic-name\"}" | jq -r '.configs[].definition.name' | sort -u | wc
> -l
> 39
> ```
> and the missing configs are all from base config:
> ```
> diff validate.txt config.txt
>
> 6,14d5
> < config.action.reload
> < connector.class
> < errors.deadletterqueue.context.headers.enable
> < errors.deadletterqueue.topic.name
> < errors.deadletterqueue.topic.replication.factor
> < errors.log.enable
> < errors.log.include.messages
> < errors.retry.delay.max.ms
> < errors.retry.timeout
> 16d6
> < header.converter
> 24d13
> < key.converter
> 26d14
> < name
> 33d20
> < predicates
> 35,39d21
> < tasks.max
> < topics
> < topics.regex
> < transforms
> < value.converter
> ```
> Would be great to get the base configs from the same endpoint as well, so we
> could rely on it instead of using the validate endpoint to get all configs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
