Hello Kafka wizards!

Congratulations on achieving beta on the 0.8 release! We've been waiting too long for it!
I have two questions regarding the high level consumer in 0.8 used from scala:

I found this example on how to use the high level consumer from Java: https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
I would like to see a similar example written in Scala. I looked under the test folder but I didn't see something similar there (one that uses a thread pool).  I would appreciate if you can point me to an example or send me a code snippet.

 Also, if I have a consumer for only one topic do I still need the thread pool? Can you send me a short scala snippet on how you would initialize and use a consumer for only one topic?


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