🚀 New & Improvements

• RabbitMQ Cluster Configuration – When configuring a cluster using RabbitMQ, SSL configuration items defined in the factory now take precedence. (#1734)
• RabbitMQ MessageId Mapping – CAP now maps its internal MessageId to RabbitMQ’s BasicProperties.MessageId, enabling direct tracking of CAP messages within RabbitMQ monitoring tools. (#1740)
• Kafka Topic Creation – CAP now respects the allow.auto.create.topics setting. When disabled, CAP will no longer auto-create topics, aligning with Kafka’s configuration and updated documentation. (#1741)
• MongoDB Cleanup Logging – Improved logging for cases where MongoDB indexes do not exist during cleanup operations. (#1742)
• RabbitMQ Consumer Optimization – Improved consumer logic by setting QoS (prefetch) to 1 by default, preventing excessive message prefetching and reducing memory pressure.
• Delayed Message Delivery – Added support for parallel sending of delayed messages. (#1753)

🐞 Bug Fixes

• PostgreSQL Delete Syntax – Fixed invalid SQL syntax in DELETE statements when using PostgreSQL. (#1737)
• Retry Processor – Fixed an issue where, after pausing and resuming the service (via Dispose / Bootstrap), the NeedRetry processor failed to pick up messages marked for retry. The retry mechanism now correctly resumes processing failed messages after service recovery. (#1757)