Class KafkaChunkEnricher

Namespace

Silverback.Messaging.Sequences.Chunking

Assembly

Silverback.Integration.Kafka.dll

Enriches the produced chunks adding some additional Kafka-specific headers.

public class KafkaChunkEnricher : IChunkEnricher

Inheritance

object

KafkaChunkEnricher

Implements

IChunkEnricher

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaChunkEnricher()

public KafkaChunkEnricher()

Methods

GetFirstChunkMessageHeader(IOutboundEnvelope)

Gets an optional header to be appended to each chunk, pointing to the first message in the sequence.

public MessageHeader? GetFirstChunkMessageHeader(IOutboundEnvelope envelope)

Parameters

envelope IOutboundEnvelope

The envelope containing the first chunk.

Returns

MessageHeader

An optional header to be appended to all subsequent chunks.