What you did is correct. Could you try running it as a standalone app and
not from scala REPL?
Thanks,
Jun
On Tue, Jul 16, 2013 at 9:21 AM, prashant amar wrote:
> Hello All
>
> I have been attempting to build an end-to-end example of producer with
> multiple consumers using scala.
> I managed
Hello All
I have been attempting to build an end-to-end example of producer with
multiple consumers using scala.
I managed to build a producer, but when I attempt to build a consumer the
following statement causes the scala REPL to block/hang
val consumerMap = consumer.createMessageStreams(topicC