многопоточном режиме?
декілька процесів запустити
Второй процесс висит и не читает сообщения
В документации же написано как!
Читал, не нашел
Надо конфиг мессенджера и как консюмер запускаешь.
framework: messenger: transports: async: dsn: '%env(MESSENGER_TRANSPORT_DSN)%' options: producer: group.id: 'main_group' log.connection.close: 'false' queue.buffering.max.messages: 100000 consumer: group.id: 'main_group' auto.offset.reset: 'smallest' log.connection.close: 'false' topicName: 'events' flushRetries: 5 flushTimeout: 10000 commitAsync: true receiveTimeout: 10000 routing: '*': async bin/console messenger:consume --no-reset -vv
сколько партиций у кафки?
10 ставил может конфиг не апдейтнулся, ща гляну
Да, с конфигом (партициями) были проблемы. Обновился, все стало ок. СПАСИБО!
Обсуждают сегодня