Влияние небольшого размера партии на скорость производителя для асинхронной отправки - PullRequest
0 голосов
/ 07 июня 2019

Я разработал производителя Kafka, который отправляет сообщения асинхронно. Для меня такой производитель не должен ограничиваться никакими вещами, но я вижу, что производительность уменьшается с уменьшением размера партии. Я хотел знать, почему это происходит?

См. https://github.com/mryf323/UtegDataDissemination/blob/master/Untitled.ipynb для дальнейшей статистики.

for (;;i.add(1)) {
            String message = sg.generate();

            ProducerRecord<String, String> record =
                    new ProducerRecord<>(appProps.getProperty("topic"), message);
            producer.send(record);
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...