Queued.Max.Requests раньше это был скорее ограничивающая настройка. сейчас читаю, возможно

и уже смысл стала иметь, пробовал кто ставить 5000-10000?

11 ответов

8 просмотров

думаете что упираетесь? а num.network.threads увеличивали? за NetworkProcessorAvgIdlePercent следите ?

Старый-Хрыч Автор вопроса
Anton Churkin
думаете что упираетесь? а num.network.threads увел...

ну думаю, знаю, часть сервисов не могут записать, num.network.threads и так 46 по числу ядер выделенных кафке

Старый-Хрыч Автор вопроса

есть, нифига интересного, ну пишется по 6 млн в минуту, читается в 2 раза больше

Старый Хрыч
есть, нифига интересного, ну пишется по 6 млн в ми...

Не, метрики именно про очередь, вдруг будет видно упирание в текущий лимит

Старый-Хрыч Автор вопроса
Старый Хрыч
надо посмотреть, не выводили ранее

чо нить типа kafka_server_request_queue_size, например. Но может быть херня, надо перебирать, их там дофига

Добый день. Поскажите, получилось проверить вот эту настройку? лучше/хуже стало? А то у меня тоже наблюдается странность - железных ресурсов куча, io, network threads куча, на стороне кафки ошибок нет, а клиенты когда их становится больше 500-600 начинают писать ошибки таймаутов записи в кафку... Думал накрутить еще network threads, background threads... Но может быть дело в предложенном вами queued.max.requests...

Старый-Хрыч Автор вопроса
Dmitriy Vityuk
Добый день. Поскажите, получилось проверить вот эт...

socket.send.buffer.bytes= socket.receive.buffer.bytes= socket.request.max.bytes= сколько? 600 клиентов это совсем копьё какой sysctl?

Старый Хрыч
socket.send.buffer.bytes= socket.receive.buffer.by...

socket.send.buffer.bytes=102400 socket.receive.buffer.bytes=102400 socket.request.max.bytes=104857600 не совсем понял, вопрос "какой sysctl" - весь вывод показать или кокретных параметров?

Старый-Хрыч Автор вопроса
Dmitriy Vityuk
socket.send.buffer.bytes=102400 socket.receive.buf...

ну ественно будет тупить socket.send.buffer.bytes=87108864 socket.receive.buffer.bytes=87108864 socket.request.max.bytes=368435456 надо хотя бы. 17 jvm zgc и 34 гб хипа

Старый Хрыч
ну ественно будет тупить socket.send.buffer.bytes=...

и тогда queued.max.requests нет смысла поднимать?

Похожие вопросы

Обсуждают сегодня

вопрос: кто как решает вопрос с динамической подгрузкой скриптов для отдельных страниц с включенным turbo router?
Sergei Toroptsev
25
Друзья, за кем?
Magic
12
Всем привет. Кто-то может подсказать, как можно перевести значения Selection поля, если список значений в нем формируется динамически? Я изначально их получаю из selection дру...
Наталья Селезнева
6
Почему Telegram пишет, что объект media не найден, хотя на самом деле я его передаю? Делаю на urllib, без зависимостей, так надо. Вызываю метод sendMediaGroup с таким JSON: ...
Alexey S
1
Сonst magicTgHTML = (text, entities) => { let processedText = text; let offsetShift = 0; entities.forEach(entity => { const { offset, length, type, url, ...
Андрей
1
Чет мне ссыкотно опять Rainlab.User в проект ставить. Кто знает, опять наотъебись все сделали или после обнов пользоваться можно?
Black Cat
10
коллеги привет. уже второй день бьемся об заклад с одной ошибкой, может вы сталкивались с таки странным поведением? есть тестовый сервер, на который паблишим релизную версию W...
Magzhan
11
это группа токсиков или тех кто помогает?
Ибрагим
9
В смысле более затратная? Общая стоимость владения лошадью меньше, чем автомобиля. В среднем.
Sergej R
10
Кстати, раз про скачивание файлов разговор зашел) Сделал бота для себя (транскрибирующего и суммаризирующего встречи) но не ожидал что за 2 месяца 10к пользователей набежит😅...
Andrey Obolenskiy
8
Карта сайта