MinimalKafka 0.8.0
dotnet add package MinimalKafka --version 0.8.0
NuGet\Install-Package MinimalKafka -Version 0.8.0
<PackageReference Include="MinimalKafka" Version="0.8.0" />
paket add MinimalKafka --version 0.8.0
#r "nuget: MinimalKafka, 0.8.0"
// Install MinimalKafka as a Cake Addin #addin nuget:?package=MinimalKafka&version=0.8.0 // Install MinimalKafka as a Cake Tool #tool nuget:?package=MinimalKafka&version=0.8.0
MinimalKafka
MinimalKafka is a Kafka consumer library designed to consume messages similarly to a Minimal API. This repository provides a streamlined and efficient way to work with Kafka consumers in .NET 8.0.
Features
- Simple and minimalistic Kafka consumer setup
- Built to integrate seamlessly with .NET 8.0 applications
- Utilizes the Confluent.Kafka for robust Kafka interactions
Installation
To install MinimalKafka, use the NuGet package manager:
dotnet add package MinimalKafka
Usage
Setting Up a Kafka Consumer
Below is a basic example of how to set up a Kafka consumer using MinimalKafka. For more detailed examples, refer to the example folder in the repository.
using MinimalKafka;
var builder = WebApplication.CreateBuilder(args);
.Services.AddMinimalKafka(config =>
{
config.WithBootstrapServers("localhost:9092")
.WithGroupId(Guid.NewGuid().ToString())
.WithOffsetReset(AutoOffsetReset.Earliest);
});
var app = builder.Build();
app.MapTopic("topic.name", (string key, string value) => {
// Implement your code here
return Task.CompletedTask;
}).WithGroupId("Topic 2");
await app.RunAsync();
Contribution
Contributions are welcome! Please submit a pull request or open an issue to discuss your ideas or improvements.
License
This project is licensed under the MIT License.
Contact
For any questions or support, please open an issue in the repository.
| 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. |
-
net8.0
- Confluent.Kafka (>= 2.6.0)
- Microsoft.AspNetCore.Http.Abstractions (>= 2.2.0)
- Microsoft.Extensions.Hosting (>= 8.0.1)
- Microsoft.Extensions.Logging.Abstractions (>= 8.0.2)
- System.Linq.Async (>= 6.0.1)
- System.Threading.Tasks.Dataflow (>= 8.0.1)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.