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 instantiat
I tried catching RuntimeException as well as catching TopicExistsException, but
the problem seems to be that the catch block is not being invoked at all.
Is it possible that the scala code needs to have an @throws annotation?
sgg
On Nov 5, 2013, at 2:24 PM, wrote:
> Hi All:
> I am trying t
Actually that will not help. The main probably swallows the exception.
On Tue, Nov 5, 2013 at 4:13 PM, Edward Capriolo wrote:
> Maybe try catching RuntimeException
>
>
> On Tue, Nov 5, 2013 at 2:24 PM, wrote:
>
>> Hi All:
>> I am trying to programmatically create Topics from a Java client.
>>
>
Maybe try catching RuntimeException
On Tue, Nov 5, 2013 at 2:24 PM, wrote:
> Hi All:
> I am trying to programmatically create Topics from a Java client.
>
> I am using a suggestion from
> http://stackoverflow.com/questions/16946778/how-can-we-create-a-topic-in-kafka-from-the-ide-using-api/18480
Hi All:
I am trying to programmatically create Topics from a Java client.
I am using a suggestion from
http://stackoverflow.com/questions/16946778/how-can-we-create-a-topic-in-kafka-from-the-ide-using-api/18480684#18480684
Essentially invoking the CreateTopicCommand.main().
String [] ar
