Foundatio.Kafka 13.0.0-beta3
Pluggable foundation blocks for building loosely coupled distributed apps.
โจ Why Choose Foundatio?
- ๐ Pluggable implementations - Swap Redis, Azure, AWS, or in-memory with no code changes
- ๐งช Developer friendly - In-memory implementations for fast local development and testing
- ๐ DI native - Built for Microsoft.Extensions.DependencyInjection
- ๐ฏ Interface-first - Code against abstractions, not implementations
- โก Production ready - Battle-tested in high-scale applications
- ๐ Consistent APIs - Same patterns across caching, queues, storage, and more
๐งฑ Core Building Blocks
| Feature | Description |
|---|---|
| Caching | In-memory, Redis, and hybrid caching with automatic invalidation |
| Queues | Reliable message queuing with Redis, Azure, AWS SQS |
| Locks | Distributed locking and throttling |
| Messaging | Pub/sub with Redis, RabbitMQ, Kafka, Azure Service Bus |
| Jobs | Background job processing with queue integration |
| File Storage | Unified file API for disk, S3, Azure Blob, and more |
| Resilience | Retry policies, circuit breakers, and timeouts |
๐ Quick Start
dotnet add package Foundatio.Kafka
// Messaging
IMessageBus messageBus = new KafkaMessageBus(o => o
.BootstrapServers("localhost:9092"));
await messageBus.PublishAsync(new MyMessage { Data = "Hello" });
๐ฆ Provider Implementations
| Provider | Caching | Queues | Messaging | Storage | Locks |
|---|---|---|---|---|---|
| In-Memory | โ | โ | โ | โ | โ |
| Redis | โ | โ | โ | โ | โ |
| Azure Storage | โ | โ | |||
| Azure Service Bus | โ | โ | |||
| AWS (S3/SQS/SNS) | โ | โ | โ | ||
| RabbitMQ | โ | ||||
| Kafka | โ | ||||
| Minio | โ | ||||
| Aliyun | โ | ||||
| SFTP | โ |
๐ Learn More
Core Features
- Getting Started - Installation and setup
- Caching - In-memory, Redis, and hybrid caching with invalidation
- Queues - FIFO message delivery with lock renewal and retry policies
- Locks - Distributed locking with null handling patterns
- Messaging - Pub/sub with size limits and notification patterns
- File Storage - Unified file API across providers
- Jobs - Background job processing and hosted service integration
Advanced Topics
- Resilience - Retry policies, circuit breakers, and timeouts
- Serialization - Serializer configuration and performance
- Dependency Injection - DI setup and patterns
- Configuration - Options and settings
๐ฆ CI Packages (Feedz)
Want the latest CI build before it hits NuGet? Add the Feedz source and install the pre-release version:
dotnet nuget add source https://f.feedz.io/foundatio/foundatio/nuget -n foundatio-feedz
dotnet add package Foundatio.Kafka --prerelease
Or add to your NuGet.config:
<configuration>
<packageSources>
<add key="foundatio-feedz" value="https://f.feedz.io/foundatio/foundatio/nuget" />
</packageSources>
<packageSourceMapping>
<packageSource key="foundatio-feedz">
<package pattern="Foundatio.*" />
</packageSource>
</packageSourceMapping>
</configuration>
๐ค Contributing
Contributions are welcome! Please feel free to submit a Pull Request. See our documentation for development guidelines.
Development Setup:
- Clone the repository
- Open
Foundatio.Kafka.slnxin Visual Studio or VS Code - Run
dotnet buildto build - Run
dotnet testto run tests
๐ License
Apache 2.0 License
Thanks to all the people who have contributed
No packages depend on Foundatio.Kafka.
https://github.com/FoundatioFx/Foundatio.Kafka/releases
.NET 8.0
- Confluent.Kafka (>= 2.13.0)
- Foundatio (>= 13.0.0-beta3)
.NET 10.0
- Confluent.Kafka (>= 2.13.0)
- Foundatio (>= 13.0.0-beta3)
| Version | Downloads | Last updated |
|---|---|---|
| 13.0.0-beta3 | 2 | 02/18/2026 |
| 13.0.0-beta1 | 4 | 01/18/2026 |
| 12.0.0 | 13 | 08/23/2025 |
| 11.1.0 | 13 | 06/13/2025 |
| 11.0.8 | 19 | 02/18/2025 |
| 11.0.6 | 16 | 02/18/2025 |
| 11.0.5 | 19 | 10/05/2024 |
| 11.0.4 | 21 | 10/06/2024 |
| 11.0.2 | 20 | 10/06/2024 |
| 10.7.1 | 20 | 10/06/2024 |
| 10.7.0 | 20 | 03/17/2024 |
| 10.6.1 | 20 | 01/05/2024 |
| 10.6.0 | 22 | 08/18/2023 |
| 10.5.1-beta1 | 21 | 03/17/2024 |