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 MockedConfluentAdminClient.
- MockedConfluentConsumerBuilder
The builder for the MockedConfluentConsumer.
- MockedConfluentProducerBuilder
The builder for the MockedConfluentProducer.
- OffsetsTracker
Keeps track of the offsets of the messages being 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.