Itmo.Dev.Platform.Kafka 1.0.61

Prefix Reserved
.NET 7.0 This package targets .NET 7.0. The package is compatible with this framework or higher.
There is a newer version of this package available.
See the version list below for details. 
dotnet add package Itmo.Dev.Platform.Kafka --version 1.0.61                

                    
                

            
NuGet\Install-Package Itmo.Dev.Platform.Kafka -Version 1.0.61
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="Itmo.Dev.Platform.Kafka" Version="1.0.61" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
paket add Itmo.Dev.Platform.Kafka --version 1.0.61                

                    
                

            
#r "nuget: Itmo.Dev.Platform.Kafka, 1.0.61"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
// Install Itmo.Dev.Platform.Kafka as a Cake Addin
#addin nuget:?package=Itmo.Dev.Platform.Kafka&version=1.0.61

// Install Itmo.Dev.Platform.Kafka as a Cake Tool
#tool nuget:?package=Itmo.Dev.Platform.Kafka&version=1.0.61

Itmo.Dev.Platform.Kafka

Platform extensions for working with Kafka

Consumer

Implement message handler

public class MyMessageHandler : IKafkaMessageHandler<int, string>
{
    public ValueTask HandleAsync(
        IEnumerable<ConsumerKafkaMessage<TKey, TValue>> messages, 
        CancellationToken cancellationToken)
    {
        foreach (var message in messages)
        {
            Console.WriteLine($"Received message, Key = {message.Key}, Value = {message.Value}");
        }
        
        return ValueTask.CompletedTask;
    }
}

Implement configuration type

public class Configuration : IKafkaConsumerConfiguration
{
    public bool IsDisabled { get; init; }

    public TimeSpan DisabledConsumerTimeout { get; init; }

    public string Host { get; set; } = string.Empty;

    public string Topic { get; init; } = string.Empty;

    public string Group { get; init; } = string.Empty;

    public int ParallelismDegree { get; init; }

    public int BufferSize { get; init; }

    public TimeSpan BufferWaitLimit { get; init; }

    public bool ReadLatest { get; init; }
}

At runtime, configuration would be received as IOptionsMonitor<TConfiguration>, so you should manually register it to DI container as options.

Add consumer to your ASP.NET server services

Consumer requires an ASP.NET host, as it is implemented as hosted service

Use extension methods to register your consumer.

collection.AddKafkaConsumer<int, string>(builder => builder
    .HandleWith<MyMessageHandler>()
    .DeserializeKeyWithNewtonsoft()
    .DeserializeValueWithNewtonsoft()
    .UseConfiguration<Configuration>());

If you want to use custom deserializer, you can call DeserializeKeyWith<T> where T : IDeserializer<T> method, same way with value deserialization.

If your topic model is defined as protobuf, you can call DeserializeKeyWithProto extension method, same way with value deserialization.

Producer

Add producer to your service collection

collection.AddKafkaProducer<int, string>(builder => builder
    .SerializeKeyWithNewtonsoft()
    .SerializeValueWithNewtonsoft()
    .UseConfiguration<Configuration>());

You can use protobuf serialization same way as it is with consumer.

Resolve producer instance from service provider

var producer = provider.GetRequiredService<IKafkaMessageProducer<int, string>>();
await producer.ProduceAsync(messages, default);
Product Compatible and additional computed target framework versions.
.NET net7.0 is compatible.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  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. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

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
2.2.234 81 11/18/2024
2.2.232 69 11/18/2024
2.2.228 74 10/31/2024
2.2.206 105 10/30/2024
2.2.204 83 10/29/2024
2.2.202 71 10/29/2024
2.1.196 70 10/29/2024
2.1.193 75 10/29/2024
2.1.190 78 10/26/2024
2.0.174 76 10/25/2024
2.0.133 70 10/25/2024
2.0.132 71 10/24/2024
2.0.131 93 10/24/2024
2.0.130 69 10/24/2024
2.0.129 75 10/24/2024
2.0.128 77 10/24/2024
2.0.127 73 10/23/2024
2.0.126 80 10/11/2024
2.0.125 78 10/11/2024
2.0.124 73 10/11/2024
2.0.123 73 10/11/2024
2.0.122 77 10/11/2024
2.0.121 77 10/11/2024
2.0.120 81 10/11/2024
2.0.119 79 10/11/2024
2.0.118 88 10/11/2024
2.0.117 80 10/10/2024
2.0.115 82 10/10/2024
2.0.113 78 10/6/2024
2.0.112 130 8/22/2024
2.0.111 141 5/14/2024
2.0.110 112 5/13/2024
2.0.109 107 5/13/2024
2.0.108 128 5/6/2024
2.0.107 109 5/6/2024
2.0.106 110 5/6/2024
2.0.105 110 5/4/2024
2.0.102 117 5/4/2024
2.0.101 107 4/26/2024
2.0.100 123 4/22/2024
2.0.99 109 4/21/2024
2.0.98 110 4/21/2024
2.0.97 104 4/19/2024
2.0.96 107 4/18/2024
2.0.95 104 4/18/2024
2.0.94 127 2/13/2024
2.0.93 123 2/10/2024
2.0.91 100 2/10/2024
2.0.90 115 2/10/2024
2.0.89 258 2/3/2024
2.0.86 105 2/1/2024
1.1.85 107 1/30/2024
1.1.83 154 1/27/2024
1.1.82 194 1/5/2024
1.1.81 282 1/3/2024
1.0.80 144 12/30/2023
1.0.79 124 12/30/2023
1.0.78 127 12/30/2023
1.0.77 137 12/28/2023
1.0.76 124 12/27/2023
1.0.75 160 12/9/2023
1.0.73 162 11/30/2023
1.0.72 142 11/27/2023
1.0.71 141 11/27/2023
1.0.70 130 11/27/2023
1.0.69 112 11/27/2023
1.0.67 144 11/25/2023
1.0.66 131 11/25/2023
1.0.65 137 11/23/2023
1.0.64 125 11/23/2023
1.0.62 129 11/18/2023
1.0.61 133 11/18/2023
1.0.60 120 11/17/2023
1.0.59 122 11/16/2023
1.0.58 118 11/13/2023
1.0.57 109 11/12/2023
1.0.56 122 11/12/2023
1.0.54 125 11/7/2023
1.0.53 127 11/4/2023
1.0.52 154 10/29/2023
1.0.51 137 10/29/2023
1.0.50 145 10/29/2023
1.0.48 129 10/29/2023

Added options post configure