Наша команда использует Kafka в качестве моей технологии организации очереди сообщений, и из-за большого объема быстрых и небольших сообщений начинает действовать регулирование, вызывающее множество проблем у наших производителей.
Я хочу уменьшить количество запросов к брокеру, пытаясь устранить это регулирование. Главное, что я изучил, - это batch.size и linger.ms, примененные к каждому производителю в конвейере и установившие для них значения 1mb и 500ms соответственно. Мне просто любопытно, что я должен изучить, чтобы это исправить.