Class KafkaMessageHeaders

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

Inheritance

object

KafkaMessageHeaders

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Messages

Assembly: Silverback.Integration.Kafka.dll

Syntax

public static class KafkaMessageHeaders

Fields

DestinationPartition

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

Declaration

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

Field Value

Type	Description
string

DestinationTopic

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

Declaration

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

Field Value

Type	Description
string

FirstChunkOffset

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

Declaration

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

Field Value

Type	Description
string

MessageKey

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

Declaration

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

Field Value

Type	Description
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.

Declaration

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

Field Value

Type	Description
string

SourceOffset

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

Declaration

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

Field Value

Type	Description
string

SourcePartition

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

Declaration

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

Field Value

Type	Description
string

SourceTimestamp

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

Declaration

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

Field Value

Type	Description
string

SourceTopic

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

Declaration

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

Field Value

Type	Description
string

Timestamp

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

Declaration

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

Field Value

Type	Description
string