Itmo.Dev.Platform.Kafka 1.1.81

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.1.81
                    


                    

                
NuGet\Install-Package Itmo.Dev.Platform.Kafka -Version 1.1.81
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.1.81" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
<PackageVersion Include="Itmo.Dev.Platform.Kafka" Version="1.1.81" />
                    


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="Itmo.Dev.Platform.Kafka" />
                    


                            Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package. 
paket add Itmo.Dev.Platform.Kafka --version 1.1.81
                    


                    

                
#r "nuget: Itmo.Dev.Platform.Kafka, 1.1.81"
#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. 
#addin nuget:?package=Itmo.Dev.Platform.Kafka&version=1.1.81
                    


                            Install Itmo.Dev.Platform.Kafka as a Cake Addin
                        

                    

                
#tool nuget:?package=Itmo.Dev.Platform.Kafka&version=1.1.81
                    


                            Install Itmo.Dev.Platform.Kafka as a Cake Tool

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.  net9.0 was computed.  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. 
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.3.261 129 2/16/2025
2.3.255 104 2/6/2025
2.3.251 111 2/3/2025
2.3.247 363 12/24/2024
2.3.237 162 11/30/2024
2.2.234 166 11/18/2024
2.2.232 95 11/18/2024
2.2.228 95 10/31/2024
2.2.206 180 10/30/2024
2.2.204 122 10/29/2024
2.2.202 94 10/29/2024
2.1.196 90 10/29/2024
2.1.193 99 10/29/2024
2.1.190 105 10/26/2024
2.0.174 98 10/25/2024
2.0.133 92 10/25/2024
2.0.132 92 10/24/2024
2.0.131 139 10/24/2024
2.0.130 94 10/24/2024
2.0.129 98 10/24/2024
2.0.128 100 10/24/2024
2.0.127 96 10/23/2024
2.0.126 100 10/11/2024
2.0.125 96 10/11/2024
2.0.124 92 10/11/2024
2.0.123 92 10/11/2024
2.0.122 96 10/11/2024
2.0.121 98 10/11/2024
2.0.120 102 10/11/2024
2.0.119 98 10/11/2024
2.0.118 112 10/11/2024
2.0.117 97 10/10/2024
2.0.115 101 10/10/2024
2.0.113 96 10/6/2024
2.0.112 145 8/22/2024
2.0.111 158 5/14/2024
2.0.110 125 5/13/2024
2.0.109 119 5/13/2024
2.0.108 145 5/6/2024
2.0.107 125 5/6/2024
2.0.106 122 5/6/2024
2.0.105 127 5/4/2024
2.0.102 135 5/4/2024
2.0.101 119 4/26/2024
2.0.100 136 4/22/2024
2.0.99 119 4/21/2024
2.0.98 122 4/21/2024
2.0.97 114 4/19/2024
2.0.96 117 4/18/2024
2.0.95 114 4/18/2024
2.0.94 142 2/13/2024
2.0.93 139 2/10/2024
2.0.91 116 2/10/2024
2.0.90 130 2/10/2024
2.0.89 274 2/3/2024
2.0.86 116 2/1/2024
1.1.85 125 1/30/2024
1.1.83 168 1/27/2024
1.1.82 205 1/5/2024
1.1.81 297 1/3/2024
1.0.80 158 12/30/2023
1.0.79 138 12/30/2023
1.0.78 139 12/30/2023
1.0.77 148 12/28/2023
1.0.76 135 12/27/2023
1.0.75 173 12/9/2023
1.0.73 168 11/30/2023
1.0.72 149 11/27/2023
1.0.71 147 11/27/2023
1.0.70 136 11/27/2023
1.0.69 121 11/27/2023
1.0.67 150 11/25/2023
1.0.66 138 11/25/2023
1.0.65 143 11/23/2023
1.0.64 131 11/23/2023
1.0.62 137 11/18/2023
1.0.61 140 11/18/2023
1.0.60 129 11/17/2023
1.0.59 132 11/16/2023
1.0.58 126 11/13/2023
1.0.57 116 11/12/2023
1.0.56 129 11/12/2023
1.0.54 134 11/7/2023
1.0.53 135 11/4/2023
1.0.52 160 10/29/2023
1.0.51 143 10/29/2023
1.0.50 151 10/29/2023
1.0.48 138 10/29/2023

Added ssl/sasl configuration