Hello Community,
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:
[WARN ] 15:56:15 org.apache.kafka.clients.NetworkClient- [AdminClient clientId=adminclient-1] Error connecting to node qdi1.5bfzmyo25mfutjqfmvvj0cmry.rx.internal.cloudapp.net:9092 (id: 0 rack: null)
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) [?:?]
Your help in this case will be appreciated.
Thank You,
Pranita
