K.EntityFrameworkCore
1.0.41
dotnet add package K.EntityFrameworkCore --version 1.0.41
NuGet\Install-Package K.EntityFrameworkCore -Version 1.0.41
<PackageReference Include="K.EntityFrameworkCore" Version="1.0.41" />
<PackageVersion Include="K.EntityFrameworkCore" Version="1.0.41" />
<PackageReference Include="K.EntityFrameworkCore" />
paket add K.EntityFrameworkCore --version 1.0.41
#r "nuget: K.EntityFrameworkCore, 1.0.41"
#:package K.EntityFrameworkCore@1.0.41
#addin nuget:?package=K.EntityFrameworkCore&version=1.0.41
#tool nuget:?package=K.EntityFrameworkCore&version=1.0.41
K-Entity-Framework Documentation
<div align="center"> <img src="docs/images/logo-full.png" alt="K-Entity-Framework Logo"> </div>
Tired of wrestling with complex Kafka setups that break Entity Framework's simplicity?
K-Entity-Framework brings the simplicity you love about EF Core directly to Apache Kafka.
Imagine producing events as naturally as saving entities, with built-in transactional safety through the outbox pattern.
No more scattered configuration files or learning yet another messaging framework. just the familiar DbContext semantics you already know.
For installation guides, tutorials, examples, and API reference, visit our DOCUMENTATION
Quick Start
builder.Services.AddDbContext<MyDbContext>(options => options
// Configure EF Core to use SQL Server
.UseSqlServer("Data Source=(LocalDB)\\MSSQLLocalDB;Integrated Security=True;Initial Catalog=Hello World")
// Enable Kafka extensibility for EF Core (publishing/consuming integration)
.UseKafkaExtensibility(builder.Configuration.GetConnectionString("Kafka")));
dbContext.Orders.Add(new Order { Id = 1232 });
// Not a block call, the event will be produced when SaveChangesAsync is called.
dbContext.OrderEvents.Produce(new OrderCreated { OrderId = 123 });
// Save and produce both.
await dbContext.SaveChangesAsync();
// here you're starting to consume kafka and moving the iterator cursor to the next offset in the assigned partitions.
await foreach (var order in dbContext.OrderEvents)
{
await dbContext.SaveChangesAsync(); // Commit message
}
💡 Want to see more examples? Check out our comprehensive documentation for advanced scenarios, configuration options, and best practices.
Why K-Entity-Framework?
Feature | K-Entity-Framework | Wolverine | MassTransit | KafkaFlow |
---|---|---|---|---|
Focus | Kafka-first with EF Core | Generic message broker | Generic message broker | Kafka-specific |
Outbox Pattern | ✅ Built-in with EF transactions | ✅ Built-in with EF transactions | ❌ Not supported for Kafka | ❌ Not suported |
Kafka Compatibility | ✅ Full Kafka support | ⚠️ Generic abstraction limitations | ⚠️ Generic abstraction limitations | ✅ Full Kafka support |
Learning Curve | ✅ Familiar EF semantics | ⚠️ New abstractions | ⚠️ New abstractions | ✅ Kafka-specific concepts |
Contributing
Contributions are welcome! Please read our contributing guidelines for details.
License
This project is licensed under the MIT License.
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 is compatible. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
-
net8.0
- Confluent.Kafka (>= 2.10.1)
- Microsoft.EntityFrameworkCore (>= 8.0.0)
- Microsoft.EntityFrameworkCore.Relational (>= 8.0.0)
- Microsoft.Extensions.Hosting (>= 8.0.0)
- Nerdbank.GitVersioning (>= 3.6.141)
- System.IO.Hashing (>= 8.0.0)
- System.Text.Json (>= 8.0.5)
-
net9.0
- Confluent.Kafka (>= 2.10.1)
- Microsoft.EntityFrameworkCore (>= 9.0.0)
- Microsoft.EntityFrameworkCore.Relational (>= 9.0.0)
- Microsoft.Extensions.Hosting (>= 9.0.0)
- Nerdbank.GitVersioning (>= 3.6.141)
- System.IO.Hashing (>= 9.0.0)
- System.Text.Json (>= 9.0.0)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.
Version | Downloads | Last Updated |
---|---|---|
1.0.41 | 150 | 9/22/2025 |
1.0.30 | 131 | 9/9/2025 |
1.0.21 | 145 | 9/3/2025 |
1.0.20 | 122 | 9/2/2025 |
1.0.19 | 124 | 9/2/2025 |
1.0.18 | 123 | 9/2/2025 |
1.0.17 | 129 | 9/2/2025 |
1.0.16 | 122 | 9/2/2025 |
1.0.15 | 126 | 9/2/2025 |
1.0.14 | 131 | 9/2/2025 |
1.0.13 | 124 | 9/2/2025 |
1.0.12 | 125 | 9/2/2025 |
1.0.9 | 133 | 9/2/2025 |
1.0.8 | 129 | 9/2/2025 |
1.0.7 | 129 | 9/2/2025 |
1.0.6 | 130 | 9/2/2025 |
1.0.5 | 129 | 9/2/2025 |
1.0.3 | 129 | 9/2/2025 |