Class KafkaChunkEnricher

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

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()

Namespace: Silverback.Messaging.Sequences.Chunking

Assembly: Silverback.Integration.Kafka.dll

Syntax

public class KafkaChunkEnricher : IChunkEnricher

Constructors

KafkaChunkEnricher()

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

Declaration

public KafkaChunkEnricher()

Methods

GetFirstChunkMessageHeader(IOutboundEnvelope)

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

Declaration

public MessageHeader? GetFirstChunkMessageHeader(IOutboundEnvelope envelope)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope	The envelope containing the first chunk.

Returns

Type	Description
MessageHeader	An optional header to be appended to all subsequent chunks.

Implements

IChunkEnricher