SerializationExtensions Class

Defines extension methods for handling Kafka message serialization to and from time-series measurements.

Inheritance Hierarchy

SystemObject
KafkaAdaptersSerializationExtensions

Namespace: KafkaAdapters
Assembly: KafkaAdapters (in KafkaAdapters.dll) Version: 2.4.207-beta

Syntax

C++

JavaScript

Copy

public static class SerializationExtensions

<ExtensionAttribute>
Public NotInheritable Class SerializationExtensions

[ExtensionAttribute]
public ref class SerializationExtensions abstract sealed

[<AbstractClassAttribute>]
[<SealedAttribute>]
[<ExtensionAttribute>]
type SerializationExtensions = class end

KafkaAdapters.SerializationExtensions = function();

Type.createClass(
	'KafkaAdapters.SerializationExtensions');

View Source

The SerializationExtensions type exposes the following members.

Methods

	Name	Description
	DeriveQualityFlags	Derive Kafka time-seres data quality flags from measurement state flags
	DeriveStateFlags	Derive measurement state flags from Kafka time-seres data quality flags
	KafkaDeserialize	Deserializes a Kafka message into a time-series Measurement.
	KakfaSerialize	Serializes a time-series IMeasurement instance into key-value buffers for a Kafka message.

Top

Fields

	Name	Description
	DecodeVersion	Defines the current message decoding version.
	KeySize	Defines the size of serialized Kafka measurement key.
	ValueSize	Defines the size of serialized Kafka measurement value.

Top

Remarks

The goal of this serialization implementation is to make it very simple to deserialize Kafka time-series messages from other language implementations, such as C++ or Java.

Reference

KafkaAdapters Namespace