Protocol definitions for Kafka.

Kafka version: 4.2.0

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

The namespace Kafka.Protocol contains generated protocol definitions based on the message specifications found in the apache/kafka repository together with basic value types extracted from the Kafka protocol guide. The Record Batch and Record are manually rolled and provided based on the documentation found here.

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

Log events are generated using an EventSource that can be subscribed on using an EventListener. Have a look at LogEventListener for an example.

Avoid subscribing on verbose log events in a production environment as it includes yaml serialized .NET Kafka message representations which can be quite resource intense and can add a substantial amount of latency. Pretty useful though for test purposes if you need visualization of what data the messages contain in a human readable way.