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(topicCountMap) Am I missing anything here? Can anybody please point me to a simple producer with multiple consumers example in scala? *Please do not point me to ConsumerConsumer or MirrorMaker as both of them are fairly complex to even look at (given that I am a novice scala programmer)* Any help will be appreciated? Thanks in advance Amar
