Protocol definitions for Kafka.
Kafka version: 3.9.0
https://www.nuget.org/packages/kafka.protocol
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.
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.