Re: Sample Kafka Producer/Consumer example in Scala

2013-07-21 Thread Jun Rao
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

Sample Kafka Producer/Consumer example in Scala

2013-07-16 Thread prashant amar
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