We are trying to establish a connection with Kafka in Talend Studio. The connection is being established successfully, but while using the `tKafkaInput` and `tKafkaCreateTopic` components, we are facing the following error:
java.net.UnknownHostException: No such host is known (qdi1.5bfzmyo25mfutjqfmvvj0cmry.rx.internal.cloudapp.net)
at java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) ~[?:?] at java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:934) ~[?:?] at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1543) ~[?:?] at java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:852) ~[?:?] at java.net.InetAddress.getAllByName0(InetAddress.java:1533) ~[?:?] at java.net.InetAddress.getAllByName(InetAddress.java:1385) ~[?:?] at java.net.InetAddress.getAllByName(InetAddress.java:1306) ~[?:?] at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:510) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:467) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:173) ~[kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:1030) [kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:301) [kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.sendEligibleCalls(KafkaAdminClient.java:1141) [kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.processRequests(KafkaAdminClient.java:1401) [kafka-clients-3.5.1.jar:?] at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1344) [kafka-clients-3.5.1.jar:?] at java.lang.Thread.run(Thread.java:840) [?:?]
