КафкаПроизводители с DirectByteBuffer - PullRequest
0 голосов
/ 25 декабря 2018

В Java-приложении, интенсивно использующем память, наличие нескольких экземпляров KafkaProducer, отправляющих большие строки json (1-1,5 МБ) в KafkaBrokers с настройкой buffer.memory на более высокое значение (скажем, 256 МБ), вызывает частые сборщики мусора.Мне нужен большой буфер для компенсации разрыва между высокой пропускной способностью сообщений, генерирующих приложения, и медленной скоростью отправки сообщений KafkaProducer в KafkaBrokers.Существует ли версия библиотеки KafkaProducer, которая использует прямой буфер (вне кучи) вместо буферов кучи (вызов ByteBuffer.allocate ()).Это разумное решение для изучения или есть другие способы улучшить производительность в случае отправки больших сообщений брокерам?

...