Here's another Reactive API: https://github.com/akka/reactive-kafka
It was developed by Software Mill <https://softwaremill.com/> and it's now
being integrated with Akka <http://akka.io>.
dean
Dean Wampler, Ph.D.
Author: Programming Scala, 2nd Edition
<http:/
You don't have the Scala library on the app class path, which is used to
implement Akka.
Use the same version that's required for the Akka libraries you're using.
http://mvnrepository.com/artifact/org.scala-lang/scala-library
dean
Dean Wampler, Ph.D.
Author: Programming Sca
Could you format that so it's readable?
Dean Wampler, Ph.D.
Author: Programming Scala, 2nd Edition
<http://shop.oreilly.com/product/0636920033073.do> (O'Reilly)
Lightbend <http://lightbend.com>
@deanwampler <http://twitter.com/deanwampler>
http://polyglotprogramming.
Okay, the type parameters with the variances need to be after the method
name, like this:
private def createNewConsumer[K <: java.util.ArrayList[Byte],V <:
java.util.ArrayList[Byte]](): KafkaConsumer[K,V] = {...}
Dean Wampler, Ph.D.
Author: Programming Scala, 2nd Edition
<http://shop.or
}
object KCLL2 extends Protocol2 {
type Stuff = List[Long]
def createStuff(): List[Long] = List.empty[Long]
}
val kcalb2 = KCALB2.createStuff()// kcalb2: java.util.ArrayList[Byte] =
[]
val kcll2 = KCLL2.createStuff() // kcll2: List[Long] = List()
HTH,
Dean
Dean Wampler, Ph.D.
Autho
Kafka support.
http://www.lightbend.com/fast-data-platform.
dean
*Dean Wampler, Ph.D.*
*VP, Fast Data Engineering at Lightbend*
Author: Programming Scala, 2nd Edition
<http://shop.oreilly.com/product/0636920033073.do>, Fast Data Architectures
for Streaming Applications
<http://www.oreilly