Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Re: Sample Kafka Producer/Consumer example in Scala


Copy link to this message
-
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?

Thanks,

Jun
On Tue, Jul 16, 2013 at 9:21 AM, prashant amar <[EMAIL PROTECTED]> wrote:

> 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
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB