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 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

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.