Class PublisherKafkaTransactionExtensions

Namespace

Silverback.Messaging.Transactions

Assembly

Silverback.Integration.Kafka.dll

Adds the InitKafkaTransaction(IPublisher, string?) method to the Silverback.Messaging.Publishing.Publisher.

public static class PublisherKafkaTransactionExtensions

Inheritance

object

PublisherKafkaTransactionExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

InitKafkaTransaction(IPublisher, string?)

Initializes the Kafka transaction.

public static IKafkaTransaction InitKafkaTransaction(this IPublisher publisher, string? transactionalIdSuffix = null)

Parameters

publisher IPublisher

The IPublisher.

transactionalIdSuffix string

The optional suffix to be appended to the transactional Id. This must be used to allow multiple concurrent transactions.

Returns

IKafkaTransaction

The created IKafkaTransaction.