[KAFKA-7253] The connector type responded by worker is always null when creating connector - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Minor
Resolution: Fixed
Affects Version/s: 1.0.0, 1.0.1, 1.0.2, 1.1.0, 1.1.1, 2.0.0
Fix Version/s: 2.2.0, 2.1.1, 2.0.2
Component/s: None
Labels:
None

Description

                        // Note that we use the updated connector config despite the fact that we don't have an updated
                        // snapshot yet. The existing task info should still be accurate.
                        Map<String, String> map = configState.connectorConfig(connName);
                        ConnectorInfo info = new ConnectorInfo(connName, config, configState.tasks(connName),
                            map == null ? null : connectorTypeForClass(map.get(ConnectorConfig.CONNECTOR_CLASS_CONFIG)));

the null map causes the null type in response. The connector class name can be taken from the config of request instead since we require the config should contain the connector class name.