Skip to content

Fresa/Kafka.Protocol

Repository files navigation

Kafka.Protocol

Protocol definitions for Kafka.

Continuous Delivery

Kafka version: 3.9.0

Download

https://www.nuget.org/packages/kafka.protocol

Getting Started

KafkaProtocol.cs contains auto-generated protocol definitions based on the official message specifications found in the offical apache/kafka repository together with generated basic value types extracted from the Kafka protocol guide. The Record Batch and Record are not available as specifications so these are manually rolled and provided based on the documentation found here.

There is a test framework for integration testing clients like Confluent.Kafka etc.

v2.x

This version introduce some breaking changes due to breaking changes in the Kafka Protocol definition itself (mostly subtle property names changes), see the release notes for further details.

A major improvement is supporting optional tagged fields, which also introduces flexible message versions which includes a more effecient way of serializing some primitives. More information kan be found in KIP-482.