Namespace Silverback.Messaging.Broker.Kafka

Classes

ConfluentAdminClientBuilder

Wraps the Confluent.Kafka.AdminClientBuilder.

ConfluentConsumerBuilder

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

ConfluentProducerBuilder

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

MockedConfluentAdminClientBuilder

The builder for the MockedConfluentAdminClient.

MockedConfluentConsumerBuilder

The builder for the MockedConfluentConsumer.

MockedConfluentProducerBuilder

The builder for the MockedConfluentProducer.

OffsetsTracker

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

Interfaces

IConfluentAdminClientBuilder

Used to build the Confluent.Kafka.IAdminClient.

IConfluentConsumerBuilder

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

IConfluentProducerBuilder

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

IConfluentProducersCache

Creates and stores the Confluent.Kafka.IProducer<TKey, TValue> instances in order to reuse them for the same KafkaProducerConfig configuration.