Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> How to make an async producer with c++ libkafka?


+
Michael Cyrulnik 2014-01-25, 00:30
+
Zicfy Hsu 2014-01-26, 02:09
Copy link to this message
-
Re: How to make an async producer with c++ libkafka?
librdkafka provides an async interface:
https://github.com/edenhill/librdkafka/blob/master/rdkafka.h#L709

It is written in C but is used by C++ applications, a proper C++ interface
will be available shortly.

Regards,
Magnus
2014/1/26 Zicfy Hsu <[EMAIL PROTECTED]>

> It does not, please see Connection.cc.
>
>
> On Sat, Jan 25, 2014 at 5:18 AM, Michael Cyrulnik <[EMAIL PROTECTED]>
> wrote:
>
> >
> > Does libkafka (c++) allow one to make an async producer?  If so, how?
> >
> > Client *client;
> > client = new Client('127.0.0.1', 9092);
> > client->sendProduceRequest(new ProduceRequest(correlationId, clientId,
> > requiredAcks, timeout, produceTopicArraySize, produceTopicArray, true));
> >
> > How would I make that non-blocking?
> >
> > thanks,
> >
> > Michael
> >
> >
>