[Feat] comes with maven, which simplifies CICD's dependence on Maven (apache#688)

* [Feat] comes with maven, which simplifies CICD's dependence on Maven

Author: wolfboys

streamx-common/src/main/scala/com/streamxhub/streamx/common/util/CommandUtils.scala

@@ -19,7 +19,7 @@
 package com.streamxhub.streamx.common.util
 
 import java.io._
-import java.lang.{Iterable => JavaIter}
+import java.lang.{Iterable => JavaIterable}
 import java.util.Scanner
 import java.util.function.Consumer
 import scala.collection.JavaConversions._
@@ -30,24 +30,15 @@ object CommandUtils extends Logger {
 
   def execute(command: String): String = {
     val buffer = new StringBuffer()
-    Try {
-      val process = new ProcessBuilder(List(command)).redirectErrorStream(true).start
-      val reader = new InputStreamReader(process.getInputStream)
-      val scanner = new Scanner(reader)
-      while (scanner.hasNextLine) {
-        buffer.append(scanner.nextLine()).append("\n")
+    this.execute(List(command), new Consumer[String] {
+      override def accept(line: String): Unit = {
+        buffer.append(line).append("\n")
       }
-      processClose(process)
-      scanner.close()
-      reader.close()
-    } match {
-      case Success(_) =>
-      case Failure(e) => throw e
-    }
+    })
     buffer.toString
   }
 
-  def execute(commands: JavaIter[String], consumer: Consumer[String]): Unit = {
+  def execute(commands: JavaIterable[String], consumer: Consumer[String]): Unit = {
     Try {
       require(commands != null && commands.nonEmpty, "[StreamX] CommandUtils.execute: commands must not be null.")
       logDebug(s"Command execute:\n${commands.mkString("\n")} ")
@@ -63,7 +54,11 @@ object CommandUtils extends Logger {
       while (scanner.hasNextLine) {
         consumer.accept(scanner.nextLine)
       }
-      processClose(process)
+      process.waitFor()
+      process.getErrorStream.close()
+      process.getInputStream.close()
+      process.getOutputStream.close()
+      process.destroy()
       scanner.close()
       out.close()
     } match {
@@ -72,12 +67,4 @@ object CommandUtils extends Logger {
     }
   }
 
-  def processClose(process: Process): Unit = {
-    process.waitFor()
-    process.getErrorStream.close()
-    process.getInputStream.close()
-    process.getOutputStream.close()
-    process.destroy()
-  }
-
 }

streamx-spark/streamx-spark-core/src/main/scala/com/streamxhub/streamx/spark/core/support/kafka/offset/Offset.scala

@@ -28,6 +28,7 @@ import org.apache.spark.{SparkConf, SparkException}
 
 import java.util.Properties
 import scala.collection.mutable
+import scala.language.implicitConversions
 import scala.util.Try