반응형 Kafka1 KAFKA 와 JAVA 의 HTTP 통신 kafka 연결 부분 def conn(ip:String,count:Int): Unit ={ implicit val system = ActorSystem() implicit val materializer = ActorMaterializer() // needed for the future flatMap/onComplete in the end implicit val executionContext = system.dispatcher val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://59.28.4.28:5000/sendEmail.do?ip="+ip+"&count="+count)) responseFutur.. 2020. 7. 6. 이전 1 다음
