У меня есть цикл, который производит сообщения, вызывая что-то вроде этого.
Client *client;
client = new Client('127.0.0.1', 9092);
client->sendProduceRequest(new ProduceRequest(correlationId, clientId, requiredAcks, timeout, produceTopicArraySize, produceTopicArray, true));
Как сделать sendProduceRequest неблокирующим?
Задача ещё не решена.
Других решений пока нет …