Namespace Silverback.Messaging.Broker.Kafka

Classes

ConfluentAdminClientFactory

Wraps the Confluent.Kafka.AdminClientBuilder.

ConfluentAdminClientFactoryExtensions

Adds some convenience methods to the IConfluentAdminClientFactory interface.

ConfluentConsumerBuilder

Wraps the Confluent.Kafka.ConsumerBuilder<TKey, TValue>.

ConfluentProducerBuilder

Wraps the Confluent.Kafka.ProducerBuilder<TKey, TValue>.

MockedConfluentAdminClientFactory

The builder for the Silverback.Messaging.Broker.Kafka.Mocks.MockedConfluentAdminClient.

MockedConfluentConsumerBuilder

The builder for the Silverback.Messaging.Broker.Kafka.Mocks.MockedConfluentConsumer.

MockedConfluentProducerBuilder

The builder for the Silverback.Messaging.Broker.Kafka.Mocks.MockedConfluentProducer.

OffsetsTracker

Keeps track of the offsets of the messages being produced or consumed.

Interfaces

IConfluentAdminClientFactory

The factory used to create Confluent.Kafka.IAdminClient instances.

IConfluentConsumerBuilder

The Confluent.Kafka.IConsumer<TKey, TValue> builder used by the KafkaConsumer.

IConfluentConsumerWrapper

Wraps the underlying Confluent.Kafka.IConsumer<TKey, TValue> and handles the connection lifecycle.

IConfluentProducerBuilder

The Confluent.Kafka.IProducer<TKey, TValue> builder used by the KafkaProducer.

IConfluentProducerWrapper

Wraps the underlying Confluent.Kafka.IProducer<TKey, TValue> and handles the connection lifecycle.

IConfluentProducerWrapperFactory

Creates IConfluentProducerWrapper instances.