[
https://issues.apache.org/jira/browse/KAFKA-7253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16571106#comment-16571106
]
ASF GitHub Bot commented on KAFKA-7253:
---------------------------------------
chia7712 opened a new pull request #5470: KAFKA-7253 The connector type
responded by worker is always null when…
URL: https://github.com/apache/kafka/pull/5470
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> The connector type responded by worker is always null when creating connector
> -----------------------------------------------------------------------------
>
> Key: KAFKA-7253
> URL: https://issues.apache.org/jira/browse/KAFKA-7253
> Project: Kafka
> Issue Type: Bug
> Reporter: Chia-Ping Tsai
> Assignee: Chia-Ping Tsai
> Priority: Minor
>
> {code}
> // 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)));
> {code}
> 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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
