Class KafkaMessageHeaders

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

Inheritance

object

KafkaMessageHeaders

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Messages

Assembly: Silverback.Integration.Kafka.dll

Syntax

public static class KafkaMessageHeaders

Fields

KafkaMessageKey

The header that will be filled with the key of the message consumed from Kafka. It is also used to temporary store the key for the produced message, defined via KafkaKeyMemberAttribute.

Declaration

public const string KafkaMessageKey = "x-kafka-message-key"

Field Value

Type	Description
string

KafkaPartitionIndex

Used to temporary store the target partition index for the produced message.

Declaration

public const string KafkaPartitionIndex = "x-kafka-partition-index"

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

TimestampKey

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

Declaration

[Obsolete("Use Timestamp instead.")]
public const string TimestampKey = "x-kafka-message-timestamp"

Field Value

Type	Description
string