search

dotnetcore / CAP

Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern
http://cap.dotnetcore.xyz
MIT License
6.61k stars 1.28k forks source link

Feature Request:Subscribers can batch process messages #1553

Closed XyJoinIt closed 2 months ago

XyJoinIt commented 2 months ago

Description: When the message sender sends a large amount of data, my RabbitMQ has accumulated a lot of messages. I configured [CapSubscribe("sample.rabbitmq.hello", Group = "A", GroupConcurrent = 3)], but even after opening multiple threads on the consumer side, it still can't keep up with the consumption. After checking the documentation, it seems that there is no configuration available for batch reading. My idea is whether it is possible to set up a thread to batch read the messages in the queue for consumption, so that the messages do not accumulate in the queue.

yang-xiaodong commented 2 months ago

No plan for this, consumer need to ack for each message.