Namespace Silverback.Messaging.Broker.Kafka.Mocks

Classes

RebalanceResult

Contains the partitions that have been revoked and assigned during the rebalance operation.

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.

IInMemoryTopicCollection

The collection of Silverback.Messaging.Broker.Kafka.Mocks.InMemoryTopic being used in the current session.

IInMemoryTransactionManager

Coordinates the in-memory transactions for the IMockedConfluentProducer.

IMockedConfluentConsumer

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

IMockedConfluentProducer

A mocked implementation of Confluent.Kafka.IProducer<TKey, TValue> from Confluent.Kafka that produces to an IInMemoryTopic.

IMockedConsumerGroup

A mocked consumer group. Note that it isn't obviously possible to accurately replicate the message broker behavior and this implementation is just intended for testing purposes.

IMockedConsumerGroupsCollection

The collection of Silverback.Messaging.Broker.Kafka.Mocks.MockedConsumerGroup being used in the current session.