Class PublisherKafkaTransactionExtensions

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

Inheritance

object

PublisherKafkaTransactionExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Transactions

Assembly: Silverback.Integration.Kafka.dll

Syntax

public static class PublisherKafkaTransactionExtensions

Methods

InitKafkaTransaction(IPublisher, string?)

Initializes the Kafka transaction.

Declaration

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

Parameters

Type	Name	Description
IPublisher	publisher	The IPublisher.
string	transactionalIdSuffix	The optional suffix to be appended to the transactional Id. This must be used to allow multiple concurrent transactions.

Returns

Type	Description
IKafkaTransaction	The created IKafkaTransaction.