Namespace Silverback.Messaging.Broker.Kafka.Mocks

Interfaces

IInMemoryPartition

A mocked topic partition where the messages are just stored in memory.

A mocked topic where the messages are just stored in memory. Note that it isn't obviously possible to accurately replicate the message broker behavior and this implementation is just intended for testing purposes.

IMockedConfluentConsumer

A mocked implementation of Confluent.Kafka.IConsumer<TKey, TValue> from Confluent.Kafka that consumes from an IInMemoryTopic.