Kafka Integration mit Streaming-Funken java.net.UnknownHostException: localhost: 2181 Scala mit

Question

val reciver = KafkaUtils.createStream(ssc, "localhost:2181","spark-streaming-consumer-group", Map("spark-topic" -> 5)) 

ich den Code oben getestet. es scheint mir eine Art Ausnahme java.net.UnknownHostException: localhost: 2181

Answer 1

Die Ausnahme, sagt er kein localhost:2181 Server ist.

Also zuerst sollten Sie tun:

$ telnet localhost 2181 

Ihnen zu versichern, dass Zookeeper richtig funktioniert.

Wenn Telnet nicht wieder eine günstige Antwort

Dann sollten Sie überdenken, wie Sie Ihren Zookeeper-Server gestartet, oder überprüfen Sie Ihre /etc/hosts Datei und stellen Sie sicher, dass Sie eine Zeile wie die folgende haben:

127.0.0.1 localhost 

Wenn Telnet eine Verbindung herstellen, sollten Sie stattdessen wie folgt versuchen:

val receiver = KafkaUtils.createStream(ssc, "127.0.0.1:2181","spark-streaming-consumer-group", Map("spark-topic" -> 5)) 

Hinweis I "localhost" auf "127.0.0.1" ersetzt