Home | About | Sematext search-lucene.com search-hadoop.com
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
 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
> >
> >
>

 
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