我现在有下面的c++代码，它使用thrift发布到flume，但是我需要以非阻塞的方式使用回调在node.js中使用。

boost::shared_ptr<TTransport> socket(new TSocket(logger->host_.c_str(), logger->port_));
boost::shared_ptr<TTransport> transport(new TFramedTransport(socket));
boost::shared_ptr<TProtocol> protocol(new TCompactProtocol(transport));
map <string,string> headers;
try {
    ThriftSourceProtocolClient client(protocol);
    transport->open();
    ThriftFlumeEvent evt;

    //headers["host"] = std::string(hostname);

    evt.headers = headers;
    evt.body = message;

    client.append(evt);
    transport->close();
} catch( ... ) {
    cerr << "\tException raised!" << endl;
}

具体地说，javaapi有asyncclient，它在c++中确实存在，并且在任何地方都有文档记录。到目前为止，谷歌还没有帮到我。