Class EnsLib.Kafka.OutboundAdapter

Parameters	Properties	Methods	Queries	Indices	ForeignKeys	Triggers
1	1	2

Methods
%AddToSaveSet	%ClassIsLatestVersion	%ClassName	%ConstructClone
%DispatchClassMethod	%DispatchGetModified	%DispatchGetProperty	%DispatchMethod
%DispatchSetModified	%DispatchSetMultidimProperty	%DispatchSetProperty	%Extends
%GetParameter	%IsA	%IsModified	%New
%NormalizeObject	%ObjectModified	%OriginalNamespace	%PackageName
%RemoveFromSaveSet	%SerializeObject	%SetModified	%ValidateObject
AssignOneSetting	CheckGatewayConnection	CheckGatewayDisconnection	ClearAllAppData
ClearRuntimeAppData	ClearStaticAppData	Connect	CredentialsSet
Disconnect	EnumerateSettingsClose	EnumerateSettingsExecute	EnumerateSettingsFetch
GetMessagingClientJARPaths	GetSettings	OnGetConnections	OnInit
OnKeepalive	OnTearDown	SendMessage	SetPropertyValues
deserialize	dispatchSendRequestAsync	dispatchSendRequestSync	getCredentials
serialize

• parameter SETTINGS = "ClientID:Kafka Settings";

List of properties can be set as settings in the configuration file format is a comma separated list of property names

• property ClientID as %String(MAXLEN=100) [ InitialExpression = "KafkaProduction" ];

Kafka producer client ID.

• method OnInit() as %Status

This user callback method is called just after %OnNew()

• method SendMessage(message As EnsLib.Kafka.Message) as %Status


[USER] > [EnsLib] > [Kafka] > [OutboundAdapter]		Private Storage