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
Re: Sample Kafka Producer/Consumer example in Scala
What you did is correct. Could you try running it as a standalone app and not from scala REPL?
Jun On Tue, Jul 16, 2013 at 9:21 AM, prashant amar <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext