Skip to content

Instantly share code, notes, and snippets.

🎯
Focusing

fr3dch3n

🎯
Focusing
Block or report user

Report or block fr3dch3n

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
@fr3dch3n
fr3dch3n / Main.scala
Created Sep 29, 2018
NeverCodeAlone - Realtime Aggregation des Otto.de Event Streams
View Main.scala
object Main extends LazyLogging {
def main(args: Array[String]): Unit = {
validateMandatoryParameters()
val groupId = sys.env("GROUP_ID")
val brokerList = sys.env("KAFKA_URL")
val sourceTopic = sys.env("SOURCE_TOPIC")
val metricsTopic = sys.env("METRICS_TOPIC")
You can’t perform that action at this time.