Capacity Query Optimization: For each batch of consumed messages, a single query will be executed to retrieve the necessary capacity information using the existing "subscription_capacity_view". This will reduce the load on the database or external service providing capacity data.

• Add component tests