Я попробовал включить функцию пакетной обработки в производителе пульсаров и использовал следующие методы при создании объекта-производителя:
- enableBatching(boolean EnableBatching)
- batchingMaxBytes(int BatchingMaxBytes)
- batchingMaxMessages(int BatchMessagesMaxMessagesPerBatch)
- batchingMaxPublishDelay(long patchDelay, TimeUnit timeUnit)
** добавить сообщение в пакет, количество сообщений в пакете на данный момент 0**
Подробнее здесь: https://stackoverflow.com/questions/781 ... cer-or-not
Мобильная версия