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.

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.