Kafka, mail # user - Re: Handling Scala exceptions from ListTopicsCommand in Java - 2013-11-06, 05:12
 Search Hadoop and all its subprojects:

Switch to Plain View
+
sggraham@... 2013-11-05, 20:56
+
Edward Capriolo 2013-11-05, 21:14
+
Edward Capriolo 2013-11-05, 21:16
+
sgg 2013-11-05, 22:24
Copy link to this message
-
Re: Handling Scala exceptions from ListTopicsCommand in Java
We don't have an official client api for creating topics yet. You can try
instantiating kafka.admin.CreateTopicCommand$ and use the following method:

createTopic(zkClient: ZkClient, topic: String, numPartitions: Int = 1,
replicationFactor: Int = 1, replicaAssignmentStr: String = "")

To instantiate zkClient, do
 zkClient = new ZkClient(zkConnect, 30000, 30000, ZKStringSerializer)

Thanks,

Jun
On Tue, Nov 5, 2013 at 11:24 AM, <[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