Я новичок в реактивном программировании и пытаюсь реализовать самый простой сценарий. Я хочу отправлять сообщение в kafka каждый раз, когда файл помещается в определенную папку. Я думаю, что плохо понимаю основы ... так что, пожалуйста, не могли бы...

Можно ли обрабатывать несколько amqp-сообщений параллельно с помощью одного и того же метода, помеченного @Incoming("queue") с помощью quarkus и smallrye-reactive-messaging? Если быть более точным, у меня есть следующий класс:...