Skip to content

Add global partitioning support for external transports with docs#2316

Merged
jeremydmiller merged 1 commit intomainfrom
global-partitioning
Mar 17, 2026
Merged

Add global partitioning support for external transports with docs#2316
jeremydmiller merged 1 commit intomainfrom
global-partitioning

Conversation

@jeremydmiller
Copy link
Copy Markdown
Member

  • Add UseSharded* extension methods on GlobalPartitionedMessageTopology for RabbitMQ, Kafka, SQS, and Pulsar transports with ConfigureListening init
  • Enhance SetExternalTopology to preserve pre-configured local queues and validate slot count matching between external and local topologies
  • Add integration tests for global partitioned sharded processing across RabbitMQ, Kafka, and SQS transports
  • Add unit tests for slot count validation in GlobalPartitionedMessageTopology
  • Add global partitioning documentation section to partitioning guide and transport-specific subsections with cross-links

- Add UseSharded* extension methods on GlobalPartitionedMessageTopology for
  RabbitMQ, Kafka, SQS, and Pulsar transports with ConfigureListening init
- Enhance SetExternalTopology to preserve pre-configured local queues and
  validate slot count matching between external and local topologies
- Add integration tests for global partitioned sharded processing across
  RabbitMQ, Kafka, and SQS transports
- Add unit tests for slot count validation in GlobalPartitionedMessageTopology
- Add global partitioning documentation section to partitioning guide and
  transport-specific subsections with cross-links

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant