val reciver = KafkaUtils.createStream(ssc, "localhost:2181","spark-streaming-consumer-group", Map("spark-topic" -> 5))
j'ai testé le code ci dessus . il m'affiche un exception de type : java.net.UnknownHostException: localhost:2181
j'aitestélecode ci dessus。 il m'affiche un exception de type:java.net.UnknownHostException:localhost:2181
1 个解决方案
#1
0
L'exception dit qu'il n'existe pas de serveur localhost:2181.
L'exception dit qu'il n'existe pas de serveur localhost:2181。
Donc premièrement tu devrais faire:
Doncpremièrementutdevrais faire:
$ telnet localhost 2181
pour te rassure que Zookeeper fonctionne correctement.
pour te rassure que Zookeeper fonctionne correctement。
Si telnet ne renvoie pas une réponse favorable
Si telnet ne renvoie pasunereéponsefavor
Alors tu devrais revoir comment tu as démarré ton serveur Zookeeper, ou encore vérifier ton fichier /etc/hosts et vérifier que tu as une ligne comme celle qui suit:
Alors tu devrais revoir commenttuédémarrétonserveur Zookeeper,ouencorevérifiertonfichier / etc / hostsetvérifierquetu as une ligne comme celle qui suit:
127.0.0.1 localhost
Si telnet arrive à se connecter, tu devrais plutôt essayer comme ceci:
Si telnet到达连接器,tudevraisplutôtessayercomme ceci:
val receiver = KafkaUtils.createStream(ssc, "127.0.0.1:2181","spark-streaming-consumer-group", Map("spark-topic" -> 5))
Note que j'ai remplacé "localhost" par "127.0.0.1"
注意quej'airemplacé“localhost”par“127.0.0.1”
#1
0
L'exception dit qu'il n'existe pas de serveur localhost:2181.
L'exception dit qu'il n'existe pas de serveur localhost:2181。
Donc premièrement tu devrais faire:
Doncpremièrementutdevrais faire:
$ telnet localhost 2181
pour te rassure que Zookeeper fonctionne correctement.
pour te rassure que Zookeeper fonctionne correctement。
Si telnet ne renvoie pas une réponse favorable
Si telnet ne renvoie pasunereéponsefavor
Alors tu devrais revoir comment tu as démarré ton serveur Zookeeper, ou encore vérifier ton fichier /etc/hosts et vérifier que tu as une ligne comme celle qui suit:
Alors tu devrais revoir commenttuédémarrétonserveur Zookeeper,ouencorevérifiertonfichier / etc / hostsetvérifierquetu as une ligne comme celle qui suit:
127.0.0.1 localhost
Si telnet arrive à se connecter, tu devrais plutôt essayer comme ceci:
Si telnet到达连接器,tudevraisplutôtessayercomme ceci:
val receiver = KafkaUtils.createStream(ssc, "127.0.0.1:2181","spark-streaming-consumer-group", Map("spark-topic" -> 5))
Note que j'ai remplacé "localhost" par "127.0.0.1"
注意quej'airemplacé“localhost”par“127.0.0.1”