maasg

maasg

package so

import java.io.PrintStream
import java.net.Socket
import java.net._

import scala.concurrent.Future

class SocketHandler(socket: Socket) {
  def deliver(data: Iterator[String]): Unit = {

maasg

Keybase proof

I hereby claim:

• I am maasg on github.
• I am maasg (https://keybase.io/maasg) on keybase.
• I have a public key ASChpDgzfLIUh_ndWgJ1dBXEyYCfN9PkTdBVlYmqx6GUYgo

To claim this, I am signing this object:

maasg

Earliest Offset Reset Test Scenario

Env: Spark 2.2.0 using Kafka integration 0.10

./spark-shell  --packages org.apache.spark:spark-streaming-kafka-0-10_2.11:2.2.0

Welcome to
      ____              __
     / __/__  ___ _____/ /__

maasg

maasg

import cloudflow.sbt.CloudflowKeys.{cloudflowDockerImageName, cloudflowDockerRegistry, cloudflowDockerRepository}
import cloudflow.sbt.ImagePlugin
import sbt.{AutoPlugin, Def, taskKey}

trait Key {
  val cloudflowImageName  = taskKey[String]("The name of the Docker image to publish.")
}

object ImageNamePlugin extends AutoPlugin {
  override def requires = ImagePlugin