Class KafkaMessageHeaders

Namespace

Silverback.Messaging.Messages

Assembly

Silverback.Integration.Kafka.dll

Contains the constants with the names of the Kafka specific message headers used by Silverback.

public static class KafkaMessageHeaders

Inheritance

object

KafkaMessageHeaders

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Fields

DestinationPartition

The header containing the dynamic destination partition the message should be produced to.

public const string DestinationPartition = "xx-kafka-destination-partition"

Field Value

string

DestinationTopic

The header containing the dynamic destination topic the message should be produced to.

public const string DestinationTopic = "xx-kafka-destination-topic"

Field Value

string

FirstChunkOffset

The KafkaOffset value of the first chunk of the same message, set when producing a chunked message.

public const string FirstChunkOffset = "x-chunk-first-offset"

Field Value

string

MessageKey

The header that will be filled with the key of the message consumed from Kafka.

public const string MessageKey = "xx-message-key"

Field Value

string

SourceConsumerGroupId

This will be set by the MoveMessageErrorPolicy and will contain the GroupId of the consumer that consumed the message that failed to be processed.

public const string SourceConsumerGroupId = "x-source-consumer-group-id"

Field Value

string

SourceOffset

This will be set by the MoveMessageErrorPolicy and will contain the offset of the message that failed to be processed.

public const string SourceOffset = "x-source-offset"

Field Value

string

SourcePartition

This will be set by the MoveMessageErrorPolicy and will contain the source partition of the message that failed to be processed.

public const string SourcePartition = "x-source-partition"

Field Value

string

SourceTimestamp

This will be set by the MoveMessageErrorPolicy and will contain the timestamp of the message that failed to be processed.

public const string SourceTimestamp = "x-source-timestamp"

Field Value

string

SourceTopic

This will be set by the MoveMessageErrorPolicy and will contain the source topic of the message that failed to be processed.

public const string SourceTopic = "x-source-topic"

Field Value

string

Timestamp

The header that will be filled with the timestamp of the message consumed from Kafka.

public const string Timestamp = "x-kafka-message-timestamp"

Field Value

string