There are a bunch of examples in the unit tests and it is async.

Thanks,
Neha


On Mon, Oct 14, 2013 at 4:54 PM, hsy...@gmail.com <hsy...@gmail.com> wrote:

> Hi Neha,
>
> Thank you, but can you give an example of CreateTopicCommand.createTopic()
> and is it sync or async?
>
> Best,
> Siyuan
>
>
> On Mon, Oct 14, 2013 at 4:45 PM, Neha Narkhede <neha.narkh...@gmail.com
> >wrote:
>
> > In 0.8, the only programmatic way, other than create topic, is to use
> > CreateTopicCommand.createTopic(). This is probably something we can
> improve
> > in the forthcoming releases.
> >
> > Thanks,
> > Neha
> >
> >
> > On Mon, Oct 14, 2013 at 3:02 PM, hsy...@gmail.com <hsy...@gmail.com>
> > wrote:
> >
> > > Hi kafka,
> > >
> > > Is there a programmatic way to create topic.
> > >
> > >
> >
> http://stackoverflow.com/questions/16946778/how-can-we-create-a-topic-in-kafka-from-the-ide-using-api/18480684#18480684
> > > is toooooo hacky, plus it's not a sync function.
> > > I'm asking this because I'm writing a test case which will start kafka
> > > server, create topic, produce and consume some message(in separate
> > thread).
> > >  But it fails some time because producer start to produce before the
> > topic
> > > is created. The auto topic creation property won't work either because
> > the
> > > consumer may start get TopicMeta data before the topic is created.
> > > Thanks!
> > >
> > > Best,
> > > Siyuan
> > >
> >
>

Reply via email to