24 янв. 2023 г. · Скажем, у нас 3 партиции. c1(consumer1) теперь будет читать сообщения из первой и второй партиции, а c2 — из третьей. Добавив ещё одного ...

3 янв. 2018 г. · Сперва увеличьте количество партиций, например, до 4 или 8. Затем используйте одновременно несколько консьюмеров, которые параллельно будут ...

24 мар. 2024 г. · Создай 1 топик, разбей его на столько партиций, сколько хочешь гонять параллельных потоков. Сообщениям в Кафке ставь messageKey=groupId. Это ...

8 авг. 2022 г. · Этот класс переключается между партициями только когда в партицию отправлено определённое количество байт (задается параметром batch.size ).

29 июл. 2021 г. · Если у вас в партициях данных делятся примерно равномерно (и каждое сообщение приносит с собой приблизительно одинаковое количество работы), то ...

9 сент. 2020 г. · Первая мысль - использовать дополнительный topic, куда слать сигналы о завершении. Еще можно пересылать условный код в последних сообщениях.

Есть ситуация, когда Consumer1 читает сообщения из кафка топика. При подключении второго Consumer2 с таким же groupId, происходит перераспределение партиций, ...

У меня есть функция в которую я подаю два массива, и пытаюсь выеtсти число одинаковых элементов в обоих массивах, но вот беда, эти массивы имеют разную ...

При тестировании spring boot приложения с помощью Postman столкнулся с ошибкой которую получаю в ответ на get запрос с pathparam: the requested resource ...

Есть ситуация, когда Consumer1 читает сообщения из кафка топика. При подключении второго Consumer2 с таким же groupId, происходит перераспределение партиций, ...