卡夫卡集成：本地主機：使用的Scala

Question

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

2181我測試上面的代碼。在我看來，是一種異常的java.net.UnknownHostException的：本地主機：2181

Answer 1

例外說，他沒有localhost:2181服務器。

所以首先你應該做的：

$ telnet localhost 2181 

向您保證，動物園管理員工作正常。

如果Telnet不返回一個滿意的答覆

那麼你應該重新考慮你如何開始你的動物園管理員的服務器，或檢查/etc/hosts文件，並驗證您有類似下面的一行：

127.0.0.1 localhost 

如果遠程登錄能夠連接，則應該嘗試像這樣：

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

注意我替換爲「本地主機」到「127.0.0.1」