Class %External.Messaging.KafkaMessage

class %External.Messaging.KafkaMessage extends %External.Messaging.Message

Kafka message

Parameters	Properties	Methods	Queries	Indices	ForeignKeys	Triggers
	4

Properties
binaryValue	key	topic	value

Methods
%AddToSaveSet	%ClassIsLatestVersion	%ClassName	%ConstructClone
%DispatchClassMethod	%DispatchGetModified	%DispatchGetProperty	%DispatchMethod
%DispatchSetModified	%DispatchSetMultidimProperty	%DispatchSetProperty	%Extends
%GetParameter	%IsA	%IsModified	%JSONExport
%JSONExportToStream	%JSONExportToString	%JSONImport	%JSONNew
%New	%NormalizeObject	%ObjectModified	%OriginalNamespace
%PackageName	%RemoveFromSaveSet	%SerializeObject	%SetModified
%ValidateObject	FromJSON	FromRemoteObject	ToJSON

Subclasses
EnsLib.Kafka.Message

• property binaryValue as %Stream.GlobalBinary(%JSONINCLUDE="NONE");

Binary message value Do not set property "value" when binaryValue is used

• property key as %String(MAXLEN=1000);

Optional message value key

• property topic as %String(MAXLEN=1000);

Message topic

• property value as %String(MAXLEN="");

Message value as string If the value exceeds maximum length of IRIS string, encode/decode the string from binaryValue using UTF8.

Class Reference IRIS for UNIX 2024.1.2
Documentation Search