You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Kalpesh Patel (Jira)" <ji...@apache.org> on 2021/04/08 22:06:00 UTC
[jira] [Assigned] (KAFKA-10231) Broken Kafka Connect node to node
communication if invalid hostname is in place
[ https://issues.apache.org/jira/browse/KAFKA-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kalpesh Patel reassigned KAFKA-10231:
-------------------------------------
Assignee: Kalpesh Patel
> Broken Kafka Connect node to node communication if invalid hostname is in place
> -------------------------------------------------------------------------------
>
> Key: KAFKA-10231
> URL: https://issues.apache.org/jira/browse/KAFKA-10231
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.4.0, 2.3.1, 2.5.0, 2.4.1
> Reporter: Pere Urbon-Bayes
> Assignee: Kalpesh Patel
> Priority: Minor
>
> As a Kafka Connect operator I would expect a more definitive error when the internal node to node communication can't happen.
> If the hostname contains an invalid character according to the [RFC1123 section 2.1|#page-13]], the error raised by the Kafka Connect worker node look like:
>
> {quote}{{[2020-06-30 10:38:49,990] ERROR Uncaught exception in REST call to /connectors (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper)}}{{java.lang.IllegalArgumentException: Invalid URI host: null (authority: kafka_connect-0.dev-2:8083)}}{{ at org.eclipse.jetty.client.HttpClient.checkHost(HttpClient.java:506)}}{{ at org.eclipse.jetty.client.HttpClient.newHttpRequest(HttpClient.java:491)}}{{ at org.eclipse.jetty.client.HttpClient.newRequest(HttpClient.java:449)}}{{ at org.eclipse.jetty.client.HttpClient.newRequest(HttpClient.java:438)}}{{ at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:83)}}{{ at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.completeOrForwardRequest(ConnectorsResource.java:309)}}{{ at org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource.createConnector(ConnectorsResource.java:138)}}
> {quote}
>
> it would be much nicer for operators that such situations are detected in similar, or improved, version as the JVM is doing in the [IDN class|#L291]].
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)