Class KafkaTransactionalProducer

Produces to an endpoint.

Inheritance

object

Producer

Producer<KafkaBroker, KafkaProducerEndpoint>

KafkaProducer

KafkaTransactionalProducer

Implements

IProducer

IDisposable

Inherited Members

KafkaProducer.Dispose()

KafkaProducer.Dispose(bool)

KafkaProducer.ProduceCore(object, Stream, IReadOnlyCollection<MessageHeader>, string)

KafkaProducer.ProduceCore(object, byte[], IReadOnlyCollection<MessageHeader>, string)

KafkaProducer.ProduceCore(object, Stream, IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)

KafkaProducer.ProduceCore(object, byte[], IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)

KafkaProducer.ProduceCoreAsync(object, Stream, IReadOnlyCollection<MessageHeader>, string)

KafkaProducer.ProduceCoreAsync(object, byte[], IReadOnlyCollection<MessageHeader>, string)

KafkaProducer.ProduceCoreAsync(object, Stream, IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)

KafkaProducer.ProduceCoreAsync(object, byte[], IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)

KafkaProducer.GetConfluentProducer()

Producer<KafkaBroker, KafkaProducerEndpoint>.Broker

Producer<KafkaBroker, KafkaProducerEndpoint>.Endpoint

Producer.Id

Producer.Broker

Producer.Endpoint

Producer.IsConnecting

Producer.IsConnected

Producer.ConnectAsync()

Producer.DisconnectAsync()

Producer.Produce(object, IReadOnlyCollection<MessageHeader>)

Producer.Produce(IOutboundEnvelope)

Producer.Produce(object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.Produce(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduce(byte[], IReadOnlyCollection<MessageHeader>)

Producer.RawProduce(Stream, IReadOnlyCollection<MessageHeader>)

Producer.RawProduce(string, byte[], IReadOnlyCollection<MessageHeader>)

Producer.RawProduce(string, Stream, IReadOnlyCollection<MessageHeader>)

Producer.RawProduce(byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduce(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduce(string, byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduce(string, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.ProduceAsync(object, IReadOnlyCollection<MessageHeader>)

Producer.ProduceAsync(IOutboundEnvelope)

Producer.ProduceAsync(object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.ProduceAsync(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduceAsync(byte[], IReadOnlyCollection<MessageHeader>)

Producer.RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>)

Producer.RawProduceAsync(string, byte[], IReadOnlyCollection<MessageHeader>)

Producer.RawProduceAsync(string, Stream, IReadOnlyCollection<MessageHeader>)

Producer.RawProduceAsync(byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduceAsync(string, byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.RawProduceAsync(string, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Producer.ConnectCoreAsync()

Producer.DisconnectCoreAsync()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class KafkaTransactionalProducer : KafkaProducer, IProducer, IDisposable

Constructors

KafkaTransactionalProducer(KafkaBroker, KafkaProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IConfluentProducersCache, IServiceProvider, IOutboundLogger<KafkaProducer>)

Initializes a new instance of the KafkaTransactionalProducer class.

Declaration

public KafkaTransactionalProducer(KafkaBroker broker, KafkaProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IConfluentProducersCache producersCache, IServiceProvider serviceProvider, IOutboundLogger<KafkaProducer> logger)

Parameters

Type	Name	Description
KafkaBroker	broker	The IBroker that instantiated this producer.
KafkaProducerEndpoint	endpoint	The endpoint to produce to.
IBrokerBehaviorsProvider<IProducerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
IConfluentProducersCache	producersCache	The IConfluentProducersCache.
IServiceProvider	serviceProvider	The IServiceProvider to be used to resolve the required services.
IOutboundLogger<KafkaProducer>	logger	The IOutboundLogger<TCategoryName>.

Methods

AbortTransaction()

Aborts the pending transaction.

Declaration

public void AbortTransaction()

BeginTransaction()

Begins a new transaction.

Declaration

public void BeginTransaction()

CommitTransaction()

Commits the pending transaction.

Declaration

public void CommitTransaction()

InitTransaction()

Initialize the transactions.

This function ensures any transactions initiated by previous instances of the producer with the same TransactionalId are completed. If the previous instance failed with a transaction in progress the previous transaction will be aborted.

This function needs to be called before any other transactional or produce functions are called when the TransactionalId is configured.

Declaration

public void InitTransaction()

Implements

IProducer

IDisposable