#35 Basic auth support (#37)

lensesio · May 13, 2020 · 5e14d8a · 5e14d8a
1 parent a987fcd
commit 5e14d8a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -12,7 +12,7 @@ Connect tools is Maven
 ## Requirements
 
 * Java 1.8
-* Gradle 3
+* Gradle 5
 
 Kafka Connect CLI
 =================

diff --git a/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala b/src/main/scala/com/datamountaineer/connect/tools/RestKafkaConnectApi.scala
@@ -34,7 +34,10 @@ object ScalajHttpClient extends HttpClient {
     */
   def request(url: java.net.URI, method: String, headers: Seq[(String, String)], reqBody: Option[String]): Try[(Int, Option[String])] = {
     try {
-      val r = Http(url.toString).headers(headers)
+      val r = (Option(url.getUserInfo).getOrElse("").split(":") match {
+        case Array(user, password) => Http(url.toString).auth(user, password)
+        case _ => Http(url.toString)
+      }).headers(headers)
       (reqBody match {
         case Some(body) => r.postData(body)
         case None => r