Interface IKafkaTransactionalProducerCollection

Namespace

Silverback.Messaging.Broker

Assembly

Silverback.Integration.Kafka.dll

Return a KafkaProducer that can be used to produce messages in a transaction. These producer are used through the KafkaTransactionalProducer.

public interface IKafkaTransactionalProducerCollection : IReadOnlyCollection<KafkaProducer>, IEnumerable<KafkaProducer>, IEnumerable

Inherited Members

IReadOnlyCollection<KafkaProducer>.Count

IEnumerable<KafkaProducer>.GetEnumerator()

Methods

GetOrCreateAsync(string, KafkaProducerConfiguration, IOutboundEnvelope, IKafkaTransaction)

Gets or creates a KafkaProducer for the specified endpoint and transaction.

ValueTask<KafkaProducer> GetOrCreateAsync(string name, KafkaProducerConfiguration configuration, IOutboundEnvelope envelope, IKafkaTransaction transaction)

Parameters

name string

The endpoint name. It could be either the topic/queue name or the friendly name.

configuration KafkaProducerConfiguration

The KafkaProducerConfiguration containing the endpoint configuration.

envelope IOutboundEnvelope

The IOutboundEnvelope containing the message to be produced.

transaction IKafkaTransaction

The IKafkaTransaction to be used to produce the messages.

Returns

ValueTask<KafkaProducer>

The KafkaProducer.