Re: handling generics in Kafka Scala

2016-09-08 Thread Dean Wampler
; [ERROR] You may wish to investigate a wildcard type such as `_ >: K`. (SLS > 3.2.10) > > [ERROR] Note: java.util.ArrayList[Byte] >: V, but Java-defined class > KafkaConsumer is invariant in type V. > > [ERROR] You may wish to investigate a wildcard type such as `_ >: V`. (SLS >

RE: handling generics in Kafka Scala

2016-09-08 Thread Martin Gainty
al Java and avoid the headache? Martin __ From: mgai...@hotmail.com To: mathieu.fenn...@replicon.com; users@kafka.apache.org Subject: RE: handling generics in Kafka Scala Date: Tue, 30 Aug 2016 23:00:29 -0400 noob with Scala so Im looking for an

RE: handling generics in Kafka Scala

2016-09-08 Thread Martin Gainty
> From: deanwamp...@gmail.com > Date: Wed, 31 Aug 2016 10:53:49 -0500 > Subject: Re: handling generics in Kafka Scala > To: users@kafka.apache.org > > Okay, the type parameters with the variances need to be after the method > name, like this: > > priv

Re: handling generics in Kafka Scala

2016-08-31 Thread Dean Wampler
GroupCommand.scala:322: > error: illegal start of simple expression > > i need 2 datatype parameter types extending java.util.ArrayList > in regular java this would be: > > public KafkaConsumer,V extends > java.util.ArrayList> createNewConsumer() { } > > this

Re: handling generics in Kafka Scala

2016-08-31 Thread Martin Gainty
r() { } this works in java but how do I setup a function or class declaration K, V whose parameter datatype extends java.util.ArrayList ? Martin >> >> From: mgai...@hotmail.com >> To: mathieu.fenn...@replicon.com; users@kafka.apache.org >> Subject: RE: handling gen

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 (O'Reilly) Lightbend @deanwampler http://polyglotprogramming.com On Tue, Aug 30, 2016 at 10

RE: handling generics in Kafka Scala

2016-08-30 Thread Martin Gainty
noob with Scala so Im looking for an experienced answer ConsumerGroupCommand.scala //private def createNewConsumer(): KafkaConsumer[String, String] = {//private def createNewConsumer(): KafkaConsumer[K extends java.util.ArrayList[Byte],V extends java.util.ArrayList[Byte]] = {private def creat