An in-memory test framework for Kafka clients which can be used to subscribe on request messages and respond with response messages. The test server can be used in-memory or connected to clients over TCP.
https://www.nuget.org/packages/kafka.testframework
The test framework can be used in-memory or by setting up a TCP socket that the kafka client can connect to. See the integration tests.
This integration test shows how a setup of the test framework with a Kafka.Confluence producer could look like.
This integration test shows how a setup of the test framework with a Kafka.Confluence consumer could look like.
Now supports Kafka.Protocol v2.x.