I'm trying to set a callback handler from java.
For that, I created a Callback Handler this way:
public class KafkaAsyncCallbackHandler implements CallbackHandler {
}
and set the property
callback.handler=com.lucid.kafka.KafkaAsyncCallbackHandler
But on runtime I get this exception coming fro
at 9:05 PM, Jun Rao wrote:
> Is your producer instantiated with type byte[]?
>
> Thanks,
>
> Jun
>
>
> On Wed, Jan 29, 2014 at 7:25 PM, Patricio Echagüe >wrote:
>
> > I'm trying to set a callback handler from java.
> >
> > For th
iating the
> producer, you need to provide 2 types, the first one for key and the second
> one for value. Make sure the second one is of type byte[].
>
> Thanks,
>
> Jun
>
>
> On Wed, Jan 29, 2014 at 10:17 PM, Patricio Echagüe >wrote:
>
> > It's Str
one more thing. Using the scala callback handler from java code seems to
work but I'm having a hard time creating scala Seqs from java code to make
my handler compatible with the scala signature.
On Thu, Jan 30, 2014 at 8:10 AM, Patricio Echagüe wrote:
> Jun, we've been using K
ull) {
return new scala.collection.mutable.ArraySeq>(0);
}
MutableList> seq = new MutableList>();
seq.$plus$eq(queueItem);
return seq;
}
Should I file an issue for this?
On Thu, Jan 30, 2014 at 9:53 AM, Patricio Echagüe wrote:
> one more thing. Using the scala callback handler from
Great work!
In addition to Dan's question, does it work with storm kafka-spout which
uses a separate zk path?
Sent from my Nexus 4.
On Mar 7, 2014 7:18 PM, "Dan Hoffman" wrote:
> Hi - am I right in that for this tool to be effective, consumers must be
> using the high level consumer or otherwis
