Re: Building API to make Kafka reactive

2016-06-29 Thread Dean Wampler
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:/

Re: Building API to make Kafka reactive

2016-07-13 Thread Dean Wampler
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

Re: handling generics in Kafka Scala

2016-08-31 Thread Dean Wampler
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.

Re: handling generics in Kafka Scala

2016-08-31 Thread Dean Wampler
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

Re: handling generics in Kafka Scala

2016-09-08 Thread Dean Wampler
} 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

Re: Kafka 24/7 support

2017-04-26 Thread Dean Wampler
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