Как создать асинхронные неблокирующие сообщения с использованием libkafka?

У меня есть цикл, который производит сообщения, вызывая что-то вроде этого.

Client *client;
client = new Client('127.0.0.1', 9092);
client->sendProduceRequest(new ProduceRequest(correlationId, clientId, requiredAcks, timeout, produceTopicArraySize, produceTopicArray, true));

Как сделать sendProduceRequest неблокирующим?

1

Решение

Задача ещё не решена.

Другие решения

Других решений пока нет …

По вопросам рекламы ammmcru@yandex.ru
Adblock
detector