kafka有异步请求/响应java api吗？

我们宁愿在生产者上使用像这样的异步请求/响应

private class MyCallback implements ResponseCallback {
    public void response(Response r) {
        //handle failure or success.  If success, ack the upstream kafka
    }
}
producer.send(request, callback);

我唯一看到的是将producer.type设置为asynch,但调用只是一个异步请求而不等待任何响应......

producer.send(request);

这不幸地迫使我进行同步,这意味着在加载时,我的线程在kafka上等待可能会开始减慢速度,因为我更愿意只用一堆请求猛击kafka并在我不断发送请求时收到响应.

谢谢,迪恩