MQContract.Kafka 2.6.1

.NET 8.0 This package targets .NET 8.0. The package is compatible with this framework or higher. 
dotnet add package MQContract.Kafka --version 2.6.1
                    


                    

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


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="MQContract.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 MQContract.Kafka --version 2.6.1
                    


                    

                
#r "nuget: MQContract.Kafka, 2.6.1"
#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. 
#:package MQContract.Kafka@2.6.1
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package. 
#addin nuget:?package=MQContract.Kafka&version=2.6.1
                    


                            Install as a Cake Addin
                        

                    

                
#tool nuget:?package=MQContract.Kafka&version=2.6.1
                    


                            Install as a Cake Tool

<a name='assembly'></a>

MQContract.Kafka

Contents

<a name='T-MQContract-Kafka-Connection'></a>

Connection type

Namespace

MQContract.Kafka

Summary

This is the MessageServiceConnection implementation for using Kafka

Parameters
Name Type Description
clientConfig T:MQContract.Kafka.Connection The Kafka Client Configuration to provide

<a name='M-MQContract-Kafka-Connection-#ctor-Confluent-Kafka-ClientConfig-'></a>

#ctor(clientConfig) constructor

Summary

This is the MessageServiceConnection implementation for using Kafka

Parameters
Name Type Description
clientConfig Confluent.Kafka.ClientConfig The Kafka Client Configuration to provide

<a name='T-MQContract-Kafka-MissingSchemaException'></a>

MissingSchemaException type

Namespace

MQContract.Kafka

Summary

Thrown when the service is unable to find a schema for a given message and it is set to fail when missing

<a name='T-MQContract-Kafka-PersistenceFailedException'></a>

PersistenceFailedException type

Namespace

MQContract.Kafka

Summary

Thrown when a publish message fails to persist in the system

<a name='T-MQContract-Kafka-SchemaValidationFailedException'></a>

SchemaValidationFailedException type

Namespace

MQContract.Kafka

Summary

Thrown when the content of a message fails to validate against the schema

<a name='T-MQContract-Kafka-Middleware-SchemaValidationMiddleware'></a>

SchemaValidationMiddleware type

Namespace

MQContract.Kafka.Middleware

Summary

Used to inject a confluent schema registry validation middleware that will use the confluent style schema registry to validate message types and attach schema information to each message

Parameters
Name Type Description
schemaRegistryClient T:MQContract.Kafka.Middleware.SchemaValidationMiddleware A schema registry client used to validate messages

<a name='M-MQContract-Kafka-Middleware-SchemaValidationMiddleware-#ctor-Confluent-SchemaRegistry-ISchemaRegistryClient,System-Boolean,System-Boolean,Confluent-SchemaRegistry-SchemaType,System-Func{System-Type,System-Threading-Tasks-ValueTask{System-String}},System-Func{Confluent-SchemaRegistry-Schema,System-IO-Stream,System-Threading-Tasks-ValueTask{System-Boolean}}-'></a>

#ctor(schemaRegistryClient,failOnMissingSchema,autoRegisterSchema,registerSchemaType,extractSchemaAsync,validateSchemaAsync) constructor

Summary

Used to inject a confluent schema registry validation middleware that will use the confluent style schema registry to validate message types and attach schema information to each message

Parameters
Name Type Description
schemaRegistryClient Confluent.SchemaRegistry.ISchemaRegistryClient A schema registry client used to validate messages
failOnMissingSchema System.Boolean Indicates if the message should fail when no schema is available
autoRegisterSchema System.Boolean Indicates if the system should attempt to register a schema when one is not found on the publish side
registerSchemaType Confluent.SchemaRegistry.SchemaType The default schema registration type to use when registering a schema
extractSchemaAsync System.Func{System.Type,System.Threading.Tasks.ValueTask{System.String}} An alternative call to generate the schema for a given message type, otherwise NJsonSchema will be used
validateSchemaAsync System.Func{Confluent.SchemaRegistry.Schema,System.IO.Stream,System.Threading.Tasks.ValueTask{System.Boolean}} An alternative call to validate the schema and the incoming message content, otherwise it will default through NJsonSchema
Product 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 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.  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. 
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.6.1 185 7/20/2025
2.6.0 120 6/27/2025
2.5.1 153 5/22/2025
2.5.0 220 5/15/2025
2.3.0 134 3/27/2025
2.2.0 101 2/21/2025
2.1.0 102 1/30/2025
2.0.1 119 12/18/2024
2.0.0 112 12/6/2024
1.1.0 118 10/3/2024
1.0.0 124 8/8/2024