dejan

import scala.collection.mutable.ListBuffer

object Factorization {

  implicit class FancyInt(val n: Int) extends AnyVal {
    def primeFactors(): List[Int] = {
      var factor = 2
      var number = n
      var factors = new ListBuffer[Int]()
      do {

dejan

package tailtopic

import org.apache.kafka.clients.consumer.KafkaConsumer
import java.util.Properties
import scala.collection.JavaConverters._
import org.apache.avro.generic.GenericRecord

object Main extends App {
  val consumerProperties = {
    val props = new Properties()