Yes , I resolve this by changing a configuration path in zookeeper
properties dataDir=/tmp/zookeeper.  I made scala code debug and got that I
have cuple of topics from previous executions. One of the topic cause the
exception.
   By the way : do I understand correct that kafka serialize the data on
disc?
What is the serialization polisy?
In case I want to delete / remove topic how can I do in using API?

Thanks
Oleg.
On Mon, Apr 8, 2013 at 6:38 AM, Swapnil Ghike <[EMAIL PROTECTED]> wrote:
 
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