Я разработал производителя 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);
}